co.cask.cdap.data2.transaction.queue.hbase

Class HBaseQueueProducer

java.lang.Object

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

co.cask.cdap.data2.transaction.queue.hbase.HBaseQueueProducer

All Implemented Interfaces:

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

public class HBaseQueueProducer
extends AbstractQueueProducer
implements Closeable

A QueueProducer that uses HBase as the storage for queue entries and consumers states.

Constructor Summary

Constructors

Constructor and Description
HBaseQueueProducer(org.apache.hadoop.hbase.client.HTable hTable, QueueName queueName, QueueMetrics queueMetrics, HBaseQueueStrategy queueStrategy, Iterable<? extends ConsumerGroupConfig> consumerGroupConfigs)

Method Summary

Methods

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

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

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

HBaseQueueProducer

public HBaseQueueProducer(org.apache.hadoop.hbase.client.HTable hTable,
                  QueueName queueName,
                  QueueMetrics queueMetrics,
                  HBaseQueueStrategy queueStrategy,
                  Iterable<? extends ConsumerGroupConfig> consumerGroupConfigs)

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

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractQueueProducer

Throws:

IOException

persist

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

Persist queue entries into HBase.

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:

IOException

doRollback

protected void doRollback()
                   throws Exception

Specified by:

doRollback in class AbstractQueueProducer

Throws:

Exception