co.cask.cdap.data2.transaction.queue.leveldb

Class LevelDBQueueConsumer

java.lang.Object

co.cask.cdap.data2.transaction.queue.AbstractQueueConsumer

co.cask.cdap.data2.transaction.queue.leveldb.LevelDBQueueConsumer

All Implemented Interfaces:

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

public final class LevelDBQueueConsumer
extends AbstractQueueConsumer

Queue consumer for levelDB.

Field Summary

Fields inherited from class co.cask.cdap.data2.transaction.queue.AbstractQueueConsumer

commitCount, stateColumnName, transaction

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	claimEntry(byte[] rowKey, byte[] stateContent)
void	close()
protected QueueScanner	getScanner(byte[] startRow, byte[] stopRow, int numRows)
void	postTxCommit()
protected void	undoState(Set<byte[]> rowKeys, byte[] stateColumnName)
protected void	updateState(Set<byte[]> rowKeys, byte[] stateColumnName, byte[] stateContent)

Methods inherited from class co.cask.cdap.data2.transaction.queue.AbstractQueueConsumer

commitTx, dequeue, dequeue, getConfig, getQueueName, getTransactionAwareName, getTxChanges, rollbackTx, startTx, updateStartRow, updateTx

Methods inherited from class java.lang.Object

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

Method Detail

postTxCommit

public void postTxCommit()

close

public void close()
           throws IOException

Throws:

IOException

claimEntry

protected boolean claimEntry(byte[] rowKey,
                 byte[] stateContent)
                      throws IOException

Specified by:

claimEntry in class AbstractQueueConsumer

Throws:

IOException

updateState

protected void updateState(Set<byte[]> rowKeys,
               byte[] stateColumnName,
               byte[] stateContent)
                    throws IOException

Specified by:

updateState in class AbstractQueueConsumer

Throws:

IOException

undoState

protected void undoState(Set<byte[]> rowKeys,
             byte[] stateColumnName)
                  throws IOException,
                         InterruptedException

Specified by:

undoState in class AbstractQueueConsumer

Throws:

IOException

InterruptedException

getScanner

protected QueueScanner getScanner(byte[] startRow,
                      byte[] stopRow,
                      int numRows)
                           throws IOException

Specified by:

getScanner in class AbstractQueueConsumer

Throws:

IOException