org.apache.beam.runners.flink.metrics

Class FlinkMetricContainer

java.lang.Object

org.apache.beam.runners.flink.metrics.FlinkMetricContainer

public class FlinkMetricContainer
extends java.lang.Object

Helper class for holding a MetricsContainerImpl and forwarding Beam metrics to Flink accumulators and metrics.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkMetricContainer.FlinkDistributionGauge Flink Gauge for DistributionResult.
static class	FlinkMetricContainer.FlinkGauge Flink Gauge for GaugeResult.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ACCUMULATOR_NAME

Constructor Summary

Constructors

Constructor and Description
FlinkMetricContainer(org.apache.flink.api.common.functions.RuntimeContext runtimeContext)

Method Summary

Modifier and Type	Method and Description
MetricsContainer	getMetricsContainer(java.lang.String stepName)
static MetricName	parseUrn(java.lang.String urn) Parse a MetricName from a BeamFnApi.MonitoringInfoUrns.Enum
void	updateMetrics(java.lang.String stepName, java.util.List<org.apache.beam.model.fnexecution.v1.BeamFnApi.MonitoringInfo> monitoringInfos)

Methods inherited from class java.lang.Object

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

Field Detail

ACCUMULATOR_NAME

public static final java.lang.String ACCUMULATOR_NAME

See Also:

Constant Field Values

Constructor Detail

FlinkMetricContainer

public FlinkMetricContainer(org.apache.flink.api.common.functions.RuntimeContext runtimeContext)

Method Detail

getMetricsContainer

public MetricsContainer getMetricsContainer(java.lang.String stepName)

parseUrn

public static MetricName parseUrn(java.lang.String urn)

Parse a MetricName from a BeamFnApi.MonitoringInfoUrns.Enum

Should be consistent with parse_namespace_and_name in monitoring_infos.py

TODO: not flink-specific; where should it live?

updateMetrics

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