Uses of Interface
co.cask.cdap.data2.transaction.queue.hbase.HBaseQueueStrategy

Packages that use HBaseQueueStrategy

Package	Description
co.cask.cdap.data2.transaction.queue.hbase	This package contains an HBase implementation of queues.

Uses of HBaseQueueStrategy in co.cask.cdap.data2.transaction.queue.hbase

Classes in co.cask.cdap.data2.transaction.queue.hbase that implement HBaseQueueStrategy

Modifier and Type	Class and Description
class	SaltedHBaseQueueStrategy A HBaseQueueStrategy that scans HBase by using the DistributedScanner.
class	ShardedHBaseQueueStrategy An implementation of HBaseQueueStrategy with sharded keys.

Methods in co.cask.cdap.data2.transaction.queue.hbase with parameters of type HBaseQueueStrategy

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

Constructors in co.cask.cdap.data2.transaction.queue.hbase with parameters of type HBaseQueueStrategy

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