org.apache.beam.sdk.metrics

Class MetricsEnvironment

java.lang.Object

org.apache.beam.sdk.metrics.MetricsEnvironment

@Experimental(value=METRICS)
 @Internal
public class MetricsEnvironment
extends java.lang.Object

Manages and provides the metrics container associated with each thread.

Users should not interact directly with this class. Instead, use Metrics and the returned objects to create and modify metrics.

The runner should create a MetricsContainer for each context in which metrics are reported (by step and name) and call setCurrentContainer(org.apache.beam.sdk.metrics.MetricsContainer) before invoking any code that may update metrics within that step. It should call setCurrentContainer(org.apache.beam.sdk.metrics.MetricsContainer) again to restore the previous container.

Alternatively, the runner can use scopedMetricsContainer(MetricsContainer) to set the container for the current thread and get a Closeable that will restore the previous container when closed.

Constructor Summary

Constructors

Constructor and Description
MetricsEnvironment()

Method Summary

Modifier and Type	Method and Description
static MetricsContainer	getCurrentContainer() Return the MetricsContainer for the current thread.
static boolean	isMetricsSupported() Indicates whether metrics reporting is supported.
static java.io.Closeable	scopedMetricsContainer(MetricsContainer container) Set the MetricsContainer for the current thread.
static MetricsContainer	setCurrentContainer(MetricsContainer container) Set the MetricsContainer for the current thread.
static void	setMetricsSupported(boolean supported) Called by the run to indicate whether metrics reporting is supported.

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricsEnvironment

public MetricsEnvironment()

Method Detail

setCurrentContainer

@Nullable
public static MetricsContainer setCurrentContainer(@Nullable
                                                             MetricsContainer container)

Set the MetricsContainer for the current thread.

Returns:

The previous container for the current thread.

setMetricsSupported

public static void setMetricsSupported(boolean supported)

Called by the run to indicate whether metrics reporting is supported.

isMetricsSupported

public static boolean isMetricsSupported()

Indicates whether metrics reporting is supported.

scopedMetricsContainer

public static java.io.Closeable scopedMetricsContainer(MetricsContainer container)

Set the MetricsContainer for the current thread.

Returns:

A Closeable that will reset the current container to the previous MetricsContainer when closed.

getCurrentContainer

@Nullable
public static MetricsContainer getCurrentContainer()

Return the MetricsContainer for the current thread.

May return null if metrics are not supported by the current runner or if the current thread is not a work-execution thread. The first time this happens in a given thread it will log a diagnostic message.