This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from f0a7ee5 Update python Dataflow API, and add FlexRS pipeline option.
(#7932)
new bd927ee mv MetricKey from runners/core-construction to core java sdk
new b93e3f5 mv MetricFiltering from runners/core-construction to core
java sdk
new 0d397b3 rm empty core/construction/metrics pkg
new 8298b55 key MetricResult by a MetricKey
new 9afacc4 Merge pull request #7867: [BEAM-4775] Key MetricResult by a
MetricKey
The 20363 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:
.../core/construction/metrics/package-info.java | 24 ---------
.../runners/core/metrics/DefaultMetricResults.java | 12 ++---
.../beam/runners/core/metrics/MetricUpdates.java | 2 +-
.../runners/core/metrics/MetricsContainerImpl.java | 4 +-
.../core/metrics/MetricsContainerStepMap.java | 6 +--
.../runners/core/metrics/MetricsTranslation.java | 2 +-
.../apache/beam/runners/direct/DirectMetrics.java | 9 ++--
.../runners/direct/portable/DirectMetrics.java | 7 ++-
.../beam/runners/direct/DirectMetricsTest.java | 2 +-
.../runners/direct/portable/DirectMetricsTest.java | 2 +-
.../extensions/metrics/MetricsHttpSink.java | 57 ++++++++++++++++++++--
.../metrics/CustomMetricQueryResults.java | 6 ++-
.../flink/metrics/FlinkMetricContainer.java | 11 +++--
.../flink/metrics/FlinkMetricContainerTest.java | 12 ++---
.../beam/runners/dataflow/DataflowMetrics.java | 12 ++---
.../worker/MetricsToCounterUpdateConverter.java | 2 +-
.../worker/StreamingStepMetricsContainer.java | 2 +-
.../worker/fn/control/BeamFnMapTaskExecutor.java | 2 +-
.../samza/metrics/SamzaMetricsContainer.java | 6 +--
.../runners/spark/metrics/SparkBeamMetric.java | 32 +++++++++---
.../runners/spark/metrics/SparkBeamMetricTest.java | 6 ++-
.../apache/beam/sdk}/metrics/MetricFiltering.java | 5 +-
.../org/apache/beam/sdk}/metrics/MetricKey.java | 8 +--
.../beam/sdk/metrics/MetricQueryResults.java | 8 +--
.../org/apache/beam/sdk/metrics/MetricResult.java | 36 ++++++--------
.../beam/sdk}/metrics/MetricFilteringTest.java | 5 +-
.../beam/sdk/metrics/MetricResultsMatchers.java | 35 ++++---------
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 2 +-
28 files changed, 151 insertions(+), 166 deletions(-)
delete mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/package-info.java
rename
{runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction
=>
sdks/java/core/src/main/java/org/apache/beam/sdk}/metrics/MetricFiltering.java
(94%)
rename
{runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction
=> sdks/java/core/src/main/java/org/apache/beam/sdk}/metrics/MetricKey.java
(86%)
rename
{runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction
=>
sdks/java/core/src/test/java/org/apache/beam/sdk}/metrics/MetricFilteringTest.java
(96%)
