co.cask.cdap.data.stream.service

Class BasicStreamWriterSizeCollector

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.cdap.data.stream.service.BasicStreamWriterSizeCollector

All Implemented Interfaces:

StreamWriterSizeCollector, com.google.common.util.concurrent.Service

public class BasicStreamWriterSizeCollector
extends com.google.common.util.concurrent.AbstractIdleService
implements StreamWriterSizeCollector

Basic implementation of a StreamWriterSizeCollector.

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

Constructor Summary

Constructors

Constructor and Description
BasicStreamWriterSizeCollector()

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.
protected void	shutDown()
protected void	startUp()

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

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

Methods inherited from class java.lang.Object

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

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

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

Constructor Detail

BasicStreamWriterSizeCollector

public BasicStreamWriterSizeCollector()

Method Detail

startUp

protected void startUp()
                throws Exception

Specified by:

startUp in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception

shutDown

protected void shutDown()
                 throws Exception

Specified by:

shutDown in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception

getStreamSizes

public Map<Id.Stream,AtomicLong> getStreamSizes()

Specified by:

getStreamSizes in interface StreamWriterSizeCollector

Returns:

the streamSizes tracked by this StreamWriterSizeCollector.

getTotalCollected

public long getTotalCollected(Id.Stream streamId)

Description copied from interface: StreamWriterSizeCollector

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

Specified by:

getTotalCollected in interface StreamWriterSizeCollector

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

public void received(Id.Stream streamId,
            long dataSize)

Description copied from interface: StreamWriterSizeCollector

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.

Specified by:

received in interface StreamWriterSizeCollector

Parameters:

streamId - Id of the stream that ingested data.

dataSize - amount of data ingested in bytes.