This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from e6d7dfe Merge pull request #6705: Inform contributors to tag PRs with
R: @reviewer
add 0abb8bf [BEAM-4553] Implement graphite sink for MetricsPusher
add 5505196 [BEAM-3310] Extract CustomQueryResults to be used in all
metrics sinks tests.
add 416b946 [BEAM-3310] Introduce NetworkMockServer to be used for all
metrics sinks tests
add 8de693e [BEAM-4553] Test Graphite metrics sink
add 9a3bc3c [BEAM-3310] improve http sink test
add ed19748 [BEAM-4553] support runners that do not support committed
metrics
add bd3b353 [BEAM-4553] Refactor MetricsGraphiteSink for code
deduplication.
add d5b32d4 [BEAM-3310] Replace Thread.sleep with a CountDownLatch in all
metrics sinks tests to avoid flakiness of the tests.
new 1d36dff Merge pull request #6569: [BEAM-4553] Implement graphite sink
for MetricsPusher and refactor MetricsHttpSink test
The 1 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:
.../extensions/metrics/MetricsGraphiteSink.java | 328 +++++++++++++++++++++
.../extensions/metrics/MetricsHttpSink.java | 4 +-
.../metrics/CustomMetricQueryResults.java | 140 +++++++++
.../metrics/MetricsGraphiteSinkTest.java | 112 +++++++
.../extensions/metrics/MetricsHttpSinkTest.java | 210 +++++--------
.../extensions/metrics/NetworkMockServer.java | 112 +++++++
.../apache/beam/sdk/options/PipelineOptions.java | 11 +
7 files changed, 782 insertions(+), 135 deletions(-)
create mode 100644
runners/extensions-java/metrics/src/main/java/org/apache/beam/runners/extensions/metrics/MetricsGraphiteSink.java
create mode 100644
runners/extensions-java/metrics/src/test/java/org/apache/beam/runners/extensions/metrics/CustomMetricQueryResults.java
create mode 100644
runners/extensions-java/metrics/src/test/java/org/apache/beam/runners/extensions/metrics/MetricsGraphiteSinkTest.java
create mode 100644
runners/extensions-java/metrics/src/test/java/org/apache/beam/runners/extensions/metrics/NetworkMockServer.java
