Uses of Interface
co.cask.cdap.data2.queue.QueueConsumer

Packages that use QueueConsumer

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.

Uses of QueueConsumer in co.cask.cdap.data2.queue

Classes in co.cask.cdap.data2.queue that implement QueueConsumer

Modifier and Type	Class and Description
class	ForwardingQueueConsumer A TransactionAware QueueConsumer that forwards all queue operations to another QueueConsumer and optionally forward transaction operations if the target QueueConsumer is also TransactionAware.

Fields in co.cask.cdap.data2.queue declared as QueueConsumer

Modifier and Type	Field and Description
protected QueueConsumer	ForwardingQueueConsumer.consumer

Methods in co.cask.cdap.data2.queue that return QueueConsumer

Modifier and Type	Method and Description
QueueConsumer	QueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)

Constructors in co.cask.cdap.data2.queue with parameters of type QueueConsumer

Constructor and Description
ForwardingQueueConsumer(QueueConsumer consumer)

Uses of QueueConsumer in co.cask.cdap.data2.transaction.queue

Classes in co.cask.cdap.data2.transaction.queue that implement QueueConsumer

Modifier and Type	Class and Description
class	AbstractQueueConsumer Common queue consumer for persisting engines such as HBase and LevelDB.

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

Methods in co.cask.cdap.data2.transaction.queue.hbase that return QueueConsumer

Modifier and Type	Method and Description
QueueConsumer	HBaseQueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)

Uses of QueueConsumer in co.cask.cdap.data2.transaction.queue.inmemory

Classes in co.cask.cdap.data2.transaction.queue.inmemory that implement QueueConsumer

Modifier and Type	Class and Description
class	InMemoryQueueConsumer Consumer for an in-memory queue.

Methods in co.cask.cdap.data2.transaction.queue.inmemory that return QueueConsumer

Modifier and Type	Method and Description
QueueConsumer	InMemoryQueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)

Uses of QueueConsumer in co.cask.cdap.data2.transaction.queue.leveldb

Classes in co.cask.cdap.data2.transaction.queue.leveldb that implement QueueConsumer

Modifier and Type	Class and Description
class	LevelDBQueueConsumer Queue consumer for levelDB.

Methods in co.cask.cdap.data2.transaction.queue.leveldb that return QueueConsumer

Modifier and Type	Method and Description
QueueConsumer	LevelDBQueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)
QueueConsumer	LevelDBAndInMemoryQueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)

Uses of QueueConsumer in co.cask.cdap.data2.transaction.stream

Constructors in co.cask.cdap.data2.transaction.stream with parameters of type QueueConsumer

Constructor and Description
QueueToStreamConsumer(Id.Stream streamId, ConsumerConfig consumerConfig, QueueConsumer consumer)