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

Class HBaseQueueUtil

java.lang.Object

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

public abstract class HBaseQueueUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
HBaseQueueUtil()

Method Summary

Methods

Modifier and Type	Method and Description
abstract 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

HBaseQueueUtil

public HBaseQueueUtil()

Method Detail

getQueueConsumer

public abstract 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)