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

Class LevelDBQueueProducer

java.lang.Object

co.cask.cdap.data2.transaction.queue.AbstractQueueProducer

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

All Implemented Interfaces:

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

public final class LevelDBQueueProducer
extends AbstractQueueProducer

A queue producer for levelDB.

Constructor Summary

Constructors

Constructor and Description
LevelDBQueueProducer(LevelDBTableCore tableCore, QueueName queueName, QueueMetrics queueMetrics)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doRollback()
protected int	persist(Iterable<QueueEntry> entries, co.cask.tephra.Transaction transaction) Persists queue entries.
void	startTx(co.cask.tephra.Transaction tx)

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

close, commitTx, enqueue, enqueue, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, updateTx

Methods inherited from class java.lang.Object

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

Constructor Detail

LevelDBQueueProducer

public LevelDBQueueProducer(LevelDBTableCore tableCore,
                    QueueName queueName,
                    QueueMetrics queueMetrics)

Method Detail

startTx

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

Specified by:

startTx in interface co.cask.tephra.TransactionAware

Overrides:

startTx in class AbstractQueueProducer

persist

protected int persist(Iterable<QueueEntry> entries,
          co.cask.tephra.Transaction transaction)
               throws Exception

Description copied from class: AbstractQueueProducer

Persists queue entries.

Specified by:

persist in class AbstractQueueProducer

Parameters:

entries - queue entries to persist.

transaction - transaction to use.

Returns:

size in bytes of the entries persisted.

Throws:

Exception

doRollback

protected void doRollback()
                   throws Exception

Specified by:

doRollback in class AbstractQueueProducer

Throws:

Exception