Uses of Class
co.cask.cdap.data2.transaction.queue.QueueEntryRow.CanConsume

Packages that use QueueEntryRow.CanConsume

Package	Description
co.cask.cdap.data2.transaction.queue	Transaction aware queue implementation.

Uses of QueueEntryRow.CanConsume in co.cask.cdap.data2.transaction.queue

Methods in co.cask.cdap.data2.transaction.queue that return QueueEntryRow.CanConsume

Modifier and Type	Method and Description
static QueueEntryRow.CanConsume	QueueEntryRow.canConsume(ConsumerConfig consumerConfig, co.cask.tephra.Transaction transaction, long enqueueWritePointer, int counter, byte[] metaValue, byte[] stateValue) Looks at specific queue entry and determines if consumer with given consumer config and current transaction can consume this entry.
static QueueEntryRow.CanConsume	QueueEntryRow.CanConsume.valueOf(String name) Returns the enum constant of this type with the specified name.
static QueueEntryRow.CanConsume[]	QueueEntryRow.CanConsume.values() Returns an array containing the constants of this enum type, in the order they are declared.