You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ch...@apache.org on 2020/08/27 20:09:45 UTC

[beam] branch master updated (faf76d5 -> d89bbfa)

This is an automated email from the ASF dual-hosted git repository.

chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from faf76d5  Merge pull request #12696: [BEAM-10701] Fix paths yet again
     add d89bbfa  [BEAM-10699] Logging BigQuery streaming insert tail latencies (#12609)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/beam/sdk/util/Histogram.java   | 217 +++++++++++++++++++++
 .../org/apache/beam/sdk/util/HistogramTest.java    | 152 +++++++++++++++
 .../LatencyRecordingHttpRequestInitializer.java    |  63 ++++++
 ...LatencyRecordingHttpRequestInitializerTest.java | 129 ++++++++++++
 .../beam/sdk/io/gcp/bigquery/BigQueryOptions.java  |  10 +-
 .../beam/sdk/io/gcp/bigquery/BigQueryServices.java |   4 +
 .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java  |  52 ++---
 .../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java |  45 ++++-
 .../sdk/io/gcp/testing/FakeBigQueryServices.java   |   6 +
 9 files changed, 653 insertions(+), 25 deletions(-)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/util/Histogram.java
 create mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/util/HistogramTest.java
 create mode 100644 sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/LatencyRecordingHttpRequestInitializer.java
 create mode 100644 sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/util/LatencyRecordingHttpRequestInitializerTest.java