You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by he...@apache.org on 2021/01/19 19:22:38 UTC
[beam] branch master updated (334020f -> cf77f03)
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