org.apache.beam.runners.jet.metrics

Class JetMetricsContainer

java.lang.Object

org.apache.beam.runners.jet.metrics.JetMetricsContainer

All Implemented Interfaces:

java.io.Serializable, MetricsContainer

public class JetMetricsContainer
extends java.lang.Object
implements MetricsContainer

Jet specific implementation of MetricsContainer.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JetMetricsContainer(java.lang.String stepName, java.lang.String ownerId, com.hazelcast.jet.core.Processor.Context context)

Method Summary

Modifier and Type	Method and Description
void	flush(boolean async)
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.
static java.lang.String	getMetricsMapName(long jobId)
StringSet	getStringSet(MetricName metricName) Return the StringSet that should be used for implementing the given metricName in this container.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.metrics.MetricsContainer

getHistogram, getMonitoringInfos, getPerWorkerCounter, getPerWorkerHistogram

Constructor Detail

JetMetricsContainer

public JetMetricsContainer(java.lang.String stepName,
                           java.lang.String ownerId,
                           com.hazelcast.jet.core.Processor.Context context)

Method Detail

getMetricsMapName

public static java.lang.String getMetricsMapName(long jobId)

getCounter

public Counter getCounter(MetricName metricName)

Description copied from interface: MetricsContainer

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

Specified by:

getCounter in interface MetricsContainer

getDistribution

public Distribution getDistribution(MetricName metricName)

Description copied from interface: MetricsContainer

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

Specified by:

getDistribution in interface MetricsContainer

getGauge

public Gauge getGauge(MetricName metricName)

Description copied from interface: MetricsContainer

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

Specified by:

getGauge in interface MetricsContainer

getStringSet

public StringSet getStringSet(MetricName metricName)

Description copied from interface: MetricsContainer

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

Specified by:

getStringSet in interface MetricsContainer

flush

public void flush(boolean async)