This is an automated email from the ASF dual-hosted git repository.
markliu pushed a commit to branch release-2.16.0
in repository https://gitbox.apache.org/repos/asf/beam.git
commit a707a116226c98325464100bef6062e81ffdc080
Merge: 9e2e8bc b5f5b81
Author: Mark Liu <mark...@apache.org>
AuthorDate: Sat Sep 28 11:59:26 2019 -0700
Merge pull request #9682: [BEAM-8314] Add aggregation logic to beam_fn_api
metric counter updat…
[BEAM-8314]: Add aggregation logic to beam_fn_api metric counter updates in
StreamingDataflowWorker
.../dataflow/worker/DataflowOperationContext.java | 3 +-
.../worker/MetricsToCounterUpdateConverter.java | 1 +
.../dataflow/worker/StreamingDataflowWorker.java | 43 +++++++++-
.../worker/counters/CounterUpdateAggregator.java | 38 +++++++++
.../worker/counters/CounterUpdateAggregators.java | 75 +++++++++++++++++
.../DistributionCounterUpdateAggregator.java | 65 +++++++++++++++
.../counters/MeanCounterUpdateAggregator.java | 55 +++++++++++++
.../counters/SumCounterUpdateAggregator.java | 47 +++++++++++
...ntMonitoringInfoToCounterUpdateTransformer.java | 3 +-
...ecMonitoringInfoToCounterUpdateTransformer.java | 3 +-
...ntMonitoringInfoToCounterUpdateTransformer.java | 3 +-
...onMonitoringInfoToCounterUpdateTransformer.java | 3 +-
...erMonitoringInfoToCounterUpdateTransformer.java | 3 +-
.../worker/BatchModeExecutionContextTest.java | 11 +--
.../dataflow/worker/IsmSideInputReaderTest.java | 3 +-
.../worker/StreamingModeExecutionContextTest.java | 5 +-
.../worker/StreamingStepMetricsContainerTest.java | 2 +-
.../dataflow/worker/WorkItemStatusClientTest.java | 9 +-
.../counters/CounterUpdateAggregatorsTest.java | 96 ++++++++++++++++++++++
.../DistributionCounterUpdateAggregatorTest.java | 72 ++++++++++++++++
.../counters/MeanCounterUpdateAggregatorTest.java | 66 +++++++++++++++
.../counters/SumCounterUpdateAggregatorTest.java | 62 ++++++++++++++
22 files changed, 647 insertions(+), 21 deletions(-)
