Uses of Package
co.cask.cdap.data2.queue

Packages that use co.cask.cdap.data2.queue

Package	Description
co.cask.cdap.data2.queue	API definition for queue for the txds2 system.
co.cask.cdap.data2.transaction.queue	Transaction aware queue implementation.
co.cask.cdap.data2.transaction.queue.hbase	This package contains an HBase implementation of queues.
co.cask.cdap.data2.transaction.queue.inmemory	This package contains in memory implementation of queues.
co.cask.cdap.data2.transaction.queue.leveldb	This package contains levelDB implementation of queues.
co.cask.cdap.data2.transaction.stream	This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.
co.cask.cdap.data2.transaction.stream.hbase	This package contains class for stream consumer implementation that uses HBase as state store.
co.cask.cdap.data2.transaction.stream.inmemory
co.cask.cdap.data2.transaction.stream.leveldb	This package contains class for stream consumer implementation that uses LevelDB as state store.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.queue

Class and Description
ConsumerConfig Contains queue consumer instance configuration.
ConsumerGroupConfig Contains queue consumer group information.
DequeueResult Represents result of an dequeue.
DequeueStrategy Strategy for dequeue.
QueueConsumer Interface for queue consumer.
QueueEntry Defines QueueEntry.
QueueProducer Implementation of this interface enqueues methods should be thread safe.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.transaction.queue

Class and Description
ConsumerConfig Contains queue consumer instance configuration.
ConsumerGroupConfig Contains queue consumer group information.
DequeueResult Represents result of an dequeue.
QueueConsumer Interface for queue consumer.
QueueEntry Defines QueueEntry.
QueueProducer Implementation of this interface enqueues methods should be thread safe.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.transaction.queue.hbase

Class and Description
ConsumerConfig Contains queue consumer instance configuration.
ConsumerGroupConfig Contains queue consumer group information.
QueueClientFactory Factory for creating QueueProducer and QueueConsumer for different queue.
QueueConsumer Interface for queue consumer.
QueueEntry Defines QueueEntry.
QueueProducer Implementation of this interface enqueues methods should be thread safe.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.transaction.queue.inmemory

Class and Description
ConsumerConfig Contains queue consumer instance configuration.
DequeueResult Represents result of an dequeue.
QueueClientFactory Factory for creating QueueProducer and QueueConsumer for different queue.
QueueConsumer Interface for queue consumer.
QueueEntry Defines QueueEntry.
QueueProducer Implementation of this interface enqueues methods should be thread safe.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.transaction.queue.leveldb

Class and Description
ConsumerConfig Contains queue consumer instance configuration.
QueueClientFactory Factory for creating QueueProducer and QueueConsumer for different queue.
QueueConsumer Interface for queue consumer.
QueueEntry Defines QueueEntry.
QueueProducer Implementation of this interface enqueues methods should be thread safe.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.transaction.stream

Class and Description
ConsumerConfig Contains queue consumer instance configuration.
DequeueResult Represents result of an dequeue.
QueueConsumer Interface for queue consumer.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.transaction.stream.hbase

Class and Description
ConsumerConfig Contains queue consumer instance configuration.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.transaction.stream.inmemory

Class and Description
ConsumerConfig Contains queue consumer instance configuration.
QueueClientFactory Factory for creating QueueProducer and QueueConsumer for different queue.

Classes in co.cask.cdap.data2.queue used by co.cask.cdap.data2.transaction.stream.leveldb

Class and Description
ConsumerConfig Contains queue consumer instance configuration.