co.cask.cdap.data.stream.service

Interface StreamWriterSizeCollector

All Superinterfaces:

com.google.common.util.concurrent.Service

All Known Implementing Classes:

BasicStreamWriterSizeCollector

public interface StreamWriterSizeCollector
extends com.google.common.util.concurrent.Service

Keep track of the sizes of the files written by one StreamHandler.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Method Summary

Methods

Modifier and Type	Method and Description
Map<Id.Stream,AtomicLong>	getStreamSizes()
long	getTotalCollected(Id.Stream streamId) Get the total amount of bytes collected for the stream streamId so far.
void	received(Id.Stream streamId, long dataSize) Called to notify this manager that dataSize bytes of data has been ingested by the stream streamId using the stream handler from which this code is executed.

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, isRunning, start, startAndWait, state, stop, stopAndWait

Method Detail

getStreamSizes

Map<Id.Stream,AtomicLong> getStreamSizes()

Returns:

the streamSizes tracked by this StreamWriterSizeCollector.

getTotalCollected

long getTotalCollected(Id.Stream streamId)

Get the total amount of bytes collected for the stream streamId so far.

Parameters:

streamId - stream Id to get the total amount of data collected for

Returns:

the total amount of bytes collected for the stream streamId so far

received

void received(Id.Stream streamId,
            long dataSize)

Called to notify this manager that dataSize bytes of data has been ingested by the stream streamId using the stream handler from which this code is executed. The dataSize is an incremental size.

Parameters:

streamId - Id of the stream that ingested data.

dataSize - amount of data ingested in bytes.