This is an automated email from the ASF dual-hosted git repository. heejong pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 334020f [BEAM-9615] Add Schema Logical Type Provider support (#13760) new 0f71eb2 [BEAM-11032] Use metric for Java BigQuery streaming insert API latency logging new 0f574ef fix checkstyle error, rename equalsMetricName new cf77f03 Merge pull request #13491 from ihji/BEAM-11032 The 30255 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../{DistributionCell.java => HistogramCell.java} | 53 +++---- .../beam/runners/core/metrics/LabeledMetrics.java | 14 ++ .../runners/core/metrics/MetricsContainerImpl.java | 101 +++++++++++++- .../core/metrics/MonitoringInfoConstants.java | 4 + .../core/metrics/MonitoringInfoMetricName.java | 2 +- .../dataflow/worker/StreamingDataflowWorker.java | 4 + .../apache/beam/sdk/metrics/DelegatingCounter.java | 11 +- ...gatingCounter.java => DelegatingHistogram.java} | 40 ++---- .../metrics/{MetricsSink.java => Histogram.java} | 11 +- .../apache/beam/sdk/metrics/MetricsContainer.java | 9 ++ .../beam/sdk/metrics/MetricsEnvironment.java | 19 +++ .../org/apache/beam/sdk/metrics/MetricsLogger.java | 66 +++++++++ .../util/{Histogram.java => HistogramData.java} | 33 ++++- .../apache/beam/sdk/util/HistogramDataTest.java | 152 +++++++++++++++++++++ .../org/apache/beam/sdk/util/HistogramTest.java | 152 --------------------- .../google-cloud-platform-core/build.gradle | 1 + .../LatencyRecordingHttpRequestInitializer.java | 23 +++- ...LatencyRecordingHttpRequestInitializerTest.java | 6 +- .../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 8 +- .../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 4 - .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 33 +++-- .../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java | 59 +++----- .../sdk/io/gcp/testing/FakeBigQueryServices.java | 6 - 23 files changed, 505 insertions(+), 306 deletions(-) copy runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/{DistributionCell.java => HistogramCell.java} (60%) copy sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/{DelegatingCounter.java => DelegatingHistogram.java} (57%) copy sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/{MetricsSink.java => Histogram.java} (76%) create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsLogger.java rename sdks/java/core/src/main/java/org/apache/beam/sdk/util/{Histogram.java => HistogramData.java} (87%) create mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/util/HistogramDataTest.java delete mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/util/HistogramTest.java