Package org.apache.beam.runners.jet.metrics

Class JetMetricsContainer

java.lang.Object

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

All Implemented Interfaces:

Serializable, MetricsContainer

public class JetMetricsContainer
extends Object
implements MetricsContainer

Jet specific implementation of MetricsContainer.

See Also:

• Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	flush(boolean async)
BoundedTrie	getBoundedTrie(MetricName metricName)	Return the BoundedTrie that should be used for implementing the given metricName in this container.
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 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

Constructor Details

JetMetricsContainer

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

Method Details

getMetricsMapName

public static 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

getBoundedTrie

public BoundedTrie getBoundedTrie(MetricName metricName)

Description copied from interface: MetricsContainer

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

Specified by:

getBoundedTrie in interface MetricsContainer

flush

public void flush(boolean async)