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

This package contains an HBase implementation of queues.

See: Description

Interface Summary

Interface	Description
HBaseQueueStrategy	Interface to represent the strategy being used in queue.

Class Summary

Class	Description
DequeueScanAttributes	Deals with dequeue scan attributes.
HBaseConsumerState	Represents state of a queue consumer.
HBaseConsumerStateStore	Class for persisting consumer state per queue consumer.
HBaseQueueAdmin	admin for queues in hbase.
HBaseQueueClientFactory	Factory for creating HBase queue producer and consumer instances.
HBaseQueueDatasetModule	Dataset module for datasets needed by the HBase queue.
HBaseQueueDatasetModule.HBaseConsumerStateStoreDefinition	Dataset definition for the HBaseConsumerStateStore.
HBaseQueueProducer	A QueueProducer that uses HBase as the storage for queue entries and consumers states.
HBaseQueueUtil
HBaseQueueUtilFactory	Factory for HBase version-specific instances of HBaseQueueUtil.
QueueBarrier	Representing queue barrier information.
SaltedHBaseQueueStrategy	A HBaseQueueStrategy that scans HBase by using the DistributedScanner.
ShardedHBaseQueueStrategy	An implementation of HBaseQueueStrategy with sharded keys.

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

This package contains an HBase implementation of queues.