org.apache.beam.sdk.metrics

Interface MetricsContainer

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

JetMetricsContainer

public interface MetricsContainer
extends java.io.Serializable

Holds the metrics for a single step. Each of the methods should return an implementation of the appropriate metrics interface for the "current" step.

Method Summary

Modifier and Type	Method and Description
Counter	getCounter(MetricName metricName) Return the Counter that should be used for implementing the given metricName in this container.
Distribution	getDistribution(MetricName metricName) Return the Distribution that should be used for implementing the given metricName in this container.
Gauge	getGauge(MetricName metricName) Return the Gauge that should be used for implementing the given metricName in this container.
default Histogram	getHistogram(MetricName metricName, org.apache.beam.sdk.util.HistogramData.BucketType bucketType) Return the Histogram that should be used for implementing the given metricName in this container.
default java.lang.Iterable<org.apache.beam.model.pipeline.v1.MetricsApi.MonitoringInfo>	getMonitoringInfos() Return the cumulative values for any metrics in this container as MonitoringInfos.
default Counter	getPerWorkerCounter(MetricName metricName) Return the Counter that should be used for implementing the given per-worker {@code metricName) in this container.
default Histogram	getPerWorkerHistogram(MetricName metricName, org.apache.beam.sdk.util.HistogramData.BucketType bucketType) Return the Histogram that should be used for implementing the given per-worker metricName in this container.

Method Detail

getCounter

Counter getCounter(MetricName metricName)

Return the Counter that should be used for implementing the given metricName in this container.

getPerWorkerCounter

default Counter getPerWorkerCounter(MetricName metricName)

Return the Counter that should be used for implementing the given per-worker {@code metricName) in this container.

getDistribution

Distribution getDistribution(MetricName metricName)

Return the Distribution that should be used for implementing the given metricName in this container.

getGauge

Gauge getGauge(MetricName metricName)

Return the Gauge that should be used for implementing the given metricName in this container.

getHistogram

default Histogram getHistogram(MetricName metricName,
                               org.apache.beam.sdk.util.HistogramData.BucketType bucketType)

Return the Histogram that should be used for implementing the given metricName in this container.

getPerWorkerHistogram

default Histogram getPerWorkerHistogram(MetricName metricName,
                                        org.apache.beam.sdk.util.HistogramData.BucketType bucketType)

Return the Histogram that should be used for implementing the given per-worker metricName in this container.

getMonitoringInfos

default java.lang.Iterable<org.apache.beam.model.pipeline.v1.MetricsApi.MonitoringInfo> getMonitoringInfos()

Return the cumulative values for any metrics in this container as MonitoringInfos.