See: Description
| Class | Description |
|---|---|
| DoFnRunnerWithMetricsUpdate<InputT,OutputT> |
DoFnRunner decorator which registers
MetricsContainerImpl. |
| FlinkMetricContainer |
Helper class for holding a
MetricsContainerImpl and forwarding Beam metrics to
Flink accumulators and metrics. |
| FlinkMetricContainer.FlinkDistributionGauge |
Flink
Gauge for DistributionResult. |
| FlinkMetricContainer.FlinkGauge |
Flink
Gauge for GaugeResult. |
| MetricsAccumulator |
Accumulator of
MetricsContainerStepMap. |
| ReaderInvocationUtil<OutputT,ReaderT extends Source.Reader<OutputT>> |
Util for invoking
Source.Reader methods that might require a
MetricsContainerImpl to be active. |