Uses of Class
co.cask.cdap.data2.queue.QueueEntry

Packages that use QueueEntry

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 QueueEntry in co.cask.cdap.data2.queue

Methods in co.cask.cdap.data2.queue with parameters of type QueueEntry

Modifier and Type	Method and Description
void	QueueProducer.enqueue(QueueEntry entry) Enqueues a QueueEntry.

Method parameters in co.cask.cdap.data2.queue with type arguments of type QueueEntry

Modifier and Type	Method and Description
void	QueueProducer.enqueue(Iterable<QueueEntry> entries) Enqueues a list of QueueEntry.

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

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

Modifier and Type	Method and Description
void	AbstractQueueProducer.enqueue(QueueEntry entry)

Method parameters in co.cask.cdap.data2.transaction.queue with type arguments of type QueueEntry

Modifier and Type	Method and Description
void	AbstractQueueProducer.enqueue(Iterable<QueueEntry> entries)
protected abstract int	AbstractQueueProducer.persist(Iterable<QueueEntry> entries, co.cask.tephra.Transaction transaction) Persists queue entries.

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

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

Modifier and Type	Method and Description
void	SaltedHBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs, QueueEntry queueEntry, byte[] rowKeyPrefix, long writePointer, int counter, Collection<byte[]> rowKeys)
void	ShardedHBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs, QueueEntry queueEntry, byte[] rowKeyPrefix, long writePointer, int counter, Collection<byte[]> rowKeys)
void	HBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs, QueueEntry queueEntry, byte[] rowKeyPrefix, long writePointer, int counter, Collection<byte[]> rowKeys) Get all the row keys that the queue entries need to write to.

Method parameters in co.cask.cdap.data2.transaction.queue.hbase with type arguments of type QueueEntry

Modifier and Type	Method and Description
protected int	HBaseQueueProducer.persist(Iterable<QueueEntry> entries, co.cask.tephra.Transaction transaction) Persist queue entries into HBase.

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

Methods in co.cask.cdap.data2.transaction.queue.inmemory with parameters of type QueueEntry

Modifier and Type	Method and Description
void	InMemoryQueue.enqueue(long txId, int seqId, QueueEntry entry)

Method parameters in co.cask.cdap.data2.transaction.queue.inmemory with type arguments of type QueueEntry

Modifier and Type	Method and Description
protected int	InMemoryQueueProducer.persist(Iterable<QueueEntry> entries, co.cask.tephra.Transaction transaction)

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

Method parameters in co.cask.cdap.data2.transaction.queue.leveldb with type arguments of type QueueEntry

Modifier and Type	Method and Description
protected int	LevelDBQueueProducer.persist(Iterable<QueueEntry> entries, co.cask.tephra.Transaction transaction)