co.cask.cdap.data2.transaction.stream

Class ForwardingStreamConsumer

java.lang.Object

co.cask.cdap.data2.transaction.stream.ForwardingStreamConsumer

All Implemented Interfaces:

StreamConsumer, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

public abstract class ForwardingStreamConsumer
extends Object
implements StreamConsumer

A StreamConsumer that forwards every methods to another StreamConsumer.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ForwardingStreamConsumer(StreamConsumer delegate)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	commitTx()
ConsumerConfig	getConsumerConfig()
Id.Stream	getStreamId()
String	getTransactionAwareName()
Collection<byte[]>	getTxChanges()
DequeueResult<co.cask.cdap.api.flow.flowlet.StreamEvent>	poll(int maxEvents, long timeout, TimeUnit timeoutUnit) Retrieves up to maxEvents of StreamEvent from the stream.
void	postTxCommit()
boolean	rollbackTx()
void	startTx(co.cask.tephra.Transaction tx)
void	updateTx(co.cask.tephra.Transaction tx)

Methods inherited from class java.lang.Object

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

Constructor Detail

ForwardingStreamConsumer

protected ForwardingStreamConsumer(StreamConsumer delegate)

Method Detail

getStreamId

public Id.Stream getStreamId()

Specified by:

getStreamId in interface StreamConsumer

Returns:

Id of the stream this consumer is consuming.

getConsumerConfig

public ConsumerConfig getConsumerConfig()

Specified by:

getConsumerConfig in interface StreamConsumer

Returns:

Configuration of this consumer.

poll

public DequeueResult<co.cask.cdap.api.flow.flowlet.StreamEvent> poll(int maxEvents,
                                                            long timeout,
                                                            TimeUnit timeoutUnit)
                                                              throws IOException,
                                                                     InterruptedException

Description copied from interface: StreamConsumer

Retrieves up to maxEvents of StreamEvent from the stream.

Specified by:

poll in interface StreamConsumer

Parameters:

maxEvents - Maximum number of events to retrieve

timeout - Maximum of time to spend on trying to read up to maxEvents

timeoutUnit - Unit for the timeout

Returns:

An instance of DequeueResult which carries StreamEvents inside.

Throws:

IOException - If there is error while reading events

InterruptedException - If interrupted while waiting

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

startTx

public void startTx(co.cask.tephra.Transaction tx)

Specified by:

startTx in interface co.cask.tephra.TransactionAware

updateTx

public void updateTx(co.cask.tephra.Transaction tx)

Specified by:

updateTx in interface co.cask.tephra.TransactionAware

getTxChanges

public Collection<byte[]> getTxChanges()

Specified by:

getTxChanges in interface co.cask.tephra.TransactionAware

commitTx

public boolean commitTx()
                 throws Exception

Specified by:

commitTx in interface co.cask.tephra.TransactionAware

Throws:

Exception

postTxCommit

public void postTxCommit()

Specified by:

postTxCommit in interface co.cask.tephra.TransactionAware

rollbackTx

public boolean rollbackTx()
                   throws Exception

Specified by:

rollbackTx in interface co.cask.tephra.TransactionAware

Throws:

Exception

getTransactionAwareName

public String getTransactionAwareName()

Specified by:

getTransactionAwareName in interface co.cask.tephra.TransactionAware