org.apache.beam.runners.flink.metrics

Class FlinkMetricContainerWithoutAccumulator

java.lang.Object

org.apache.beam.runners.flink.metrics.FlinkMetricContainerWithoutAccumulator

public class FlinkMetricContainerWithoutAccumulator
extends java.lang.Object

The base helper class for holding a MetricsContainerImpl and forwarding Beam metrics to Flink accumulators and metrics. This class is used when Flink RuntimeContext is not available.

See Also:

FlinkMetricContainer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	org.apache.beam.runners.flink.metrics.FlinkMetricContainerBase.FlinkDistributionGauge Flink Gauge for DistributionResult.
static class	org.apache.beam.runners.flink.metrics.FlinkMetricContainerBase.FlinkGauge Flink Gauge for GaugeResult.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.beam.runners.core.metrics.MetricsContainerStepMap	metricsContainers

Constructor Summary

Constructors

Constructor and Description
FlinkMetricContainerWithoutAccumulator(org.apache.flink.metrics.MetricGroup metricGroup)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.metrics.MetricGroup	getMetricGroup()
org.apache.beam.runners.core.metrics.MetricsContainerImpl	getMetricsContainer(java.lang.String stepName)
void	updateMetrics(java.lang.String stepName, java.util.List<org.apache.beam.model.pipeline.v1.MetricsApi.MonitoringInfo> monitoringInfos) Update this container with metrics from the passed MetricsApi.MonitoringInfos, and send updates along to Flink's internal metrics framework.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

metricsContainers

protected final org.apache.beam.runners.core.metrics.MetricsContainerStepMap metricsContainers

Constructor Detail

FlinkMetricContainerWithoutAccumulator

public FlinkMetricContainerWithoutAccumulator(org.apache.flink.metrics.MetricGroup metricGroup)

Method Detail

getMetricGroup

public org.apache.flink.metrics.MetricGroup getMetricGroup()

getMetricsContainer

public org.apache.beam.runners.core.metrics.MetricsContainerImpl getMetricsContainer(java.lang.String stepName)

updateMetrics

public void updateMetrics(java.lang.String stepName,
                          java.util.List<org.apache.beam.model.pipeline.v1.MetricsApi.MonitoringInfo> monitoringInfos)

Update this container with metrics from the passed MetricsApi.MonitoringInfos, and send updates along to Flink's internal metrics framework.