org.apache.beam.sdk.metrics

Interface MetricsLogger

All Superinterfaces:

java.io.Serializable

@Experimental(value=METRICS)
public interface MetricsLogger
extends java.io.Serializable

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.atomic.AtomicLong	LAST_REPORTED_MILLIS
static java.util.concurrent.locks.Lock	REPORTING_LOCK

Method Summary

Modifier and Type	Method and Description
java.lang.String	getCumulativeString(java.util.Set<MetricName> metricFilter)
Logger	getMetricLogger()
void	reset()
default void	tryLoggingMetrics(java.lang.String header, java.util.Set<MetricName> metricFilter, long minimumLoggingFrequencyMillis, boolean resetMetrics)

Field Detail

REPORTING_LOCK

static final java.util.concurrent.locks.Lock REPORTING_LOCK

LAST_REPORTED_MILLIS

static final java.util.concurrent.atomic.AtomicLong LAST_REPORTED_MILLIS

Method Detail

tryLoggingMetrics

default void tryLoggingMetrics(java.lang.String header,
                               java.util.Set<MetricName> metricFilter,
                               long minimumLoggingFrequencyMillis,
                               boolean resetMetrics)

getMetricLogger

Logger getMetricLogger()

getCumulativeString

java.lang.String getCumulativeString(java.util.Set<MetricName> metricFilter)

reset

void reset()