Package org.apache.beam.sdk.metrics

Class SourceMetrics

java.lang.Object

org.apache.beam.sdk.metrics.SourceMetrics

@Experimental(METRICS)
public class SourceMetrics
extends java.lang.Object

Standard Source Metrics.

Constructor Summary

Constructors

Constructor	Description
SourceMetrics()

Method Summary

Modifier and Type	Method	Description
static Gauge	backlogBytes()	Gauge for source backlog in bytes.
static Gauge	backlogBytesOfSplit(java.lang.String splitId)	Gauge for source split backlog in bytes.
static Gauge	backlogElements()	Gauge for source backlog in elements.
static Gauge	backlogElementsOfSplit(java.lang.String splitId)	Gauge for source split backlog in elements.
static Counter	bytesRead()	Counter of bytes read by a source.
static Counter	bytesReadBySplit(java.lang.String splitId)	Counter of bytes read by a source split.
static Counter	elementsRead()	Counter of elements read by a source.
static Counter	elementsReadBySplit(java.lang.String splitId)	Counter of elements read by a source split.

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceMetrics

public SourceMetrics()

Method Detail

elementsRead

public static Counter elementsRead()

Counter of elements read by a source.

elementsReadBySplit

public static Counter elementsReadBySplit(java.lang.String splitId)

Counter of elements read by a source split.

Should only be used when there is a small, fixed set of split IDs so as not to overload metrics backends.

bytesRead

public static Counter bytesRead()

Counter of bytes read by a source.

bytesReadBySplit

public static Counter bytesReadBySplit(java.lang.String splitId)

Counter of bytes read by a source split.

Should only be used when there is a small, fixed set of split IDs so as not to overload metrics backends.

backlogBytes

public static Gauge backlogBytes()

Gauge for source backlog in bytes.

backlogBytesOfSplit

public static Gauge backlogBytesOfSplit(java.lang.String splitId)

Gauge for source split backlog in bytes.

Should only be used when there is a small, fixed set of split IDs so as not to overload metrics backends.

backlogElements

public static Gauge backlogElements()

Gauge for source backlog in elements.

backlogElementsOfSplit

public static Gauge backlogElementsOfSplit(java.lang.String splitId)

Gauge for source split backlog in elements.

Should only be used when there is a small, fixed set of split IDs so as not to overload metrics backends.