co.cask.cdap.data.stream.service

Interface StreamMetricsCollectorFactory.StreamMetricsCollector

Enclosing interface:

StreamMetricsCollectorFactory

public static interface StreamMetricsCollectorFactory.StreamMetricsCollector

Collector of metrics for a stream.

Method Summary

Methods

Modifier and Type	Method and Description
void	emitMetrics(long bytesWritten, long eventsWritten) Emit stream metrics.

Method Detail

emitMetrics

void emitMetrics(long bytesWritten,
               long eventsWritten)

Emit stream metrics.

Parameters:

bytesWritten - number of bytes written to the stream

eventsWritten - number of events written to the stream