co.cask.cdap.data2.transaction.stream.leveldb

Class LevelDBStreamFileConsumer

java.lang.Object

co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumer

co.cask.cdap.data2.transaction.stream.leveldb.LevelDBStreamFileConsumer

All Implemented Interfaces:

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

public final class LevelDBStreamFileConsumer
extends AbstractStreamFileConsumer

Nested Class Summary

Nested classes/interfaces inherited from class co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumer

AbstractStreamFileConsumer.StateScanner

Field Summary

Fields inherited from class co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumer

MAX_SCAN_ROWS, stateColumnName

Constructor Summary

Constructors

Constructor and Description
LevelDBStreamFileConsumer(CConfiguration cConf, StreamConfig streamConfig, ConsumerConfig consumerConfig, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, ReadFilter extraFilter, LevelDBTableCore tableCore, Object dbLock)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	claimFifoEntry(byte[] row, byte[] value, byte[] oldValue)
protected AbstractStreamFileConsumer.StateScanner	scanStates(byte[] startRow, byte[] stopRow)
protected void	undoState(Iterable<byte[]> rows, int size)
protected void	updateState(Iterable<byte[]> rows, int size, byte[] value)

Methods inherited from class co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumer

close, commitTx, doClose, getConsumerConfig, getStreamId, getTransactionAwareName, getTxChanges, poll, postTxCommit, rollbackTx, startTx, toString, updateTx

Methods inherited from class java.lang.Object

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

Constructor Detail

LevelDBStreamFileConsumer

public LevelDBStreamFileConsumer(CConfiguration cConf,
                         StreamConfig streamConfig,
                         ConsumerConfig consumerConfig,
                         FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader,
                         StreamConsumerStateStore stateStore,
                         StreamConsumerState beginConsumerState,
                         @Nullable
                         ReadFilter extraFilter,
                         LevelDBTableCore tableCore,
                         Object dbLock)

Parameters:

streamConfig - Stream configuration.

consumerConfig - Consumer configuration.

reader - For reading stream events. This class is responsible for closing the reader.

Method Detail

claimFifoEntry

protected boolean claimFifoEntry(byte[] row,
                     byte[] value,
                     byte[] oldValue)
                          throws IOException

Specified by:

claimFifoEntry in class AbstractStreamFileConsumer

Throws:

IOException

updateState

protected void updateState(Iterable<byte[]> rows,
               int size,
               byte[] value)
                    throws IOException

Specified by:

updateState in class AbstractStreamFileConsumer

Throws:

IOException

undoState

protected void undoState(Iterable<byte[]> rows,
             int size)
                  throws IOException

Specified by:

undoState in class AbstractStreamFileConsumer

Throws:

IOException

scanStates

protected AbstractStreamFileConsumer.StateScanner scanStates(byte[] startRow,
                                                 byte[] stopRow)
                                                      throws IOException

Specified by:

scanStates in class AbstractStreamFileConsumer

Throws:

IOException