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

Class HBase98QueueUtil

java.lang.Object

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

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

public class HBase98QueueUtil
extends HBaseQueueUtil

HBase 0.98 implementation of HBaseQueueUtil.

Constructor Summary

Constructors

Constructor and Description
HBase98QueueUtil()

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.cdap.data2.transaction.queue.hbase.HBaseQueueConsumer	getQueueConsumer(CConfiguration cConf, org.apache.hadoop.hbase.client.HTable hTable, QueueName queueName, HBaseConsumerState consumerState, HBaseConsumerStateStore stateStore, HBaseQueueStrategy queueStrategy)

Methods inherited from class java.lang.Object

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

Constructor Detail

HBase98QueueUtil

public HBase98QueueUtil()

Method Detail

getQueueConsumer

public co.cask.cdap.data2.transaction.queue.hbase.HBaseQueueConsumer getQueueConsumer(CConfiguration cConf,
                                                                             org.apache.hadoop.hbase.client.HTable hTable,
                                                                             QueueName queueName,
                                                                             HBaseConsumerState consumerState,
                                                                             HBaseConsumerStateStore stateStore,
                                                                             HBaseQueueStrategy queueStrategy)

Specified by:

getQueueConsumer in class HBaseQueueUtil