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

Packages that use QueueProducer

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.

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

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

Modifier and Type	Method and Description
QueueProducer	QueueClientFactory.createProducer(QueueName queueName)
QueueProducer	QueueClientFactory.createProducer(QueueName queueName, QueueMetrics queueMetrics)

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

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

Modifier and Type	Class and Description
class	AbstractQueueProducer Abstract base class for QueueProducer that emits enqueue metrics post commit.

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

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

Modifier and Type	Class and Description
class	HBaseQueueProducer A QueueProducer that uses HBase as the storage for queue entries and consumers states.

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

Modifier and Type	Method and Description
QueueProducer	HBaseQueueClientFactory.createProducer(QueueName queueName)
QueueProducer	HBaseQueueClientFactory.createProducer(QueueName queueName, QueueMetrics queueMetrics)

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

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

Modifier and Type	Class and Description
class	InMemoryQueueProducer Producer for an in-memory queue.

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

Modifier and Type	Method and Description
QueueProducer	InMemoryQueueClientFactory.createProducer(QueueName queueName)
QueueProducer	InMemoryQueueClientFactory.createProducer(QueueName queueName, QueueMetrics queueMetrics)

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

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

Modifier and Type	Class and Description
class	LevelDBQueueProducer A queue producer for levelDB.

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

Modifier and Type	Method and Description
QueueProducer	LevelDBQueueClientFactory.createProducer(QueueName queueName)
QueueProducer	LevelDBAndInMemoryQueueClientFactory.createProducer(QueueName queueName)
QueueProducer	LevelDBQueueClientFactory.createProducer(QueueName queueName, QueueMetrics queueMetrics)
QueueProducer	LevelDBAndInMemoryQueueClientFactory.createProducer(QueueName queueName, QueueMetrics queueMetrics)