public class FlinkMetricContainer
extends java.lang.Object
MetricsContainerImpl
and forwarding Beam metrics to Flink
accumulators and metrics.Modifier and Type | Class and Description |
---|---|
static class |
FlinkMetricContainer.FlinkDistributionGauge
Flink
Gauge for DistributionResult . |
static class |
FlinkMetricContainer.FlinkGauge
Flink
Gauge for GaugeResult . |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ACCUMULATOR_NAME |
Constructor and Description |
---|
FlinkMetricContainer(org.apache.flink.api.common.functions.RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
MetricsContainer |
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.MonitoringInfo s, and send updates
along to Flink's internal metrics framework. |
public static final java.lang.String ACCUMULATOR_NAME
public FlinkMetricContainer(org.apache.flink.api.common.functions.RuntimeContext runtimeContext)
public MetricsContainer getMetricsContainer(java.lang.String stepName)
public void updateMetrics(java.lang.String stepName, java.util.List<org.apache.beam.model.pipeline.v1.MetricsApi.MonitoringInfo> monitoringInfos)
MetricsApi.MonitoringInfo
s, and send updates
along to Flink's internal metrics framework.