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 3d4db26 [BEAM-9547] Add tests for groupby(dropna) (#14553)
new a2c88ec1 Merge pull request #14543: [BEAM-12172] Bump gradle to 6.8.3
new 2cc3721 Merge pull request #14493 from ajamato/bq_metrics_logger
The 31645 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:
.../beam/runners/core/metrics/HistogramCell.java | 28 ++++++-
.../runners/core/metrics/MetricsContainerImpl.java | 86 +++++++++++++++-----
.../beam/runners/core/metrics/MetricsLogger.java | 88 ++++++++++++++++++++
.../core/metrics/MonitoringInfoConstants.java | 19 +++++
.../core/metrics/MetricsContainerImplTest.java | 95 ++++++++++++++++++++++
.../runners/core/metrics/MetricsLoggerTest.java | 90 ++++++++++++++++++++
.../dataflow/worker/StreamingDataflowWorker.java | 6 +-
.../org/apache/beam/sdk/metrics/MetricsLogger.java | 66 ---------------
.../org/apache/beam/sdk/util/HistogramData.java | 66 +++++++++++++--
.../apache/beam/sdk/util/HistogramDataTest.java | 53 +++++++++++-
.../sdk/io/gcp/bigquery/BatchedStreamingWrite.java | 46 +++--------
11 files changed, 507 insertions(+), 136 deletions(-)
create mode 100644
runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsLogger.java
create mode 100644
runners/core-java/src/test/java/org/apache/beam/runners/core/metrics/MetricsLoggerTest.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsLogger.java
