Package org.apache.beam.sdk.metrics

Class SinkMetrics

java.lang.Object

org.apache.beam.sdk.metrics.SinkMetrics

@Experimental(METRICS)
public class SinkMetrics
extends java.lang.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 Detail

SinkMetrics

public SinkMetrics()

Method Detail

elementsWritten

public static Counter elementsWritten()

Counter of elements written to a sink.

bytesWritten

public static Counter bytesWritten()

Counter of bytes written to a sink.