Package org.apache.beam.sdk.metrics

Class SinkMetrics

java.lang.Object

org.apache.beam.sdk.metrics.SinkMetrics

public class SinkMetrics
extends Object

Standard Sink Metrics.

Constructor Summary

Constructors

Constructor	Description
SinkMetrics()

Method Summary

Modifier and Type	Method	Description
static Counter	bytesWritten()	Counter of bytes written to a sink.
static Counter	elementsWritten()	Counter of elements written to a sink.

Methods inherited from class java.lang.Object

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

Constructor Details

SinkMetrics

public SinkMetrics()

Method Details

elementsWritten

public static Counter elementsWritten()

Counter of elements written to a sink.

bytesWritten

public static Counter bytesWritten()

Counter of bytes written to a sink.