Uses of Interface
co.cask.cdap.messaging.store.PayloadTable.Entry

Packages that use PayloadTable.Entry

Package	Description
co.cask.cdap.messaging.store

Uses of PayloadTable.Entry in co.cask.cdap.messaging.store

Classes in co.cask.cdap.messaging.store that implement PayloadTable.Entry

Modifier and Type	Class and Description
class	ImmutablePayloadTableEntry An immutable implementation of PayloadTable.Entry.

Methods in co.cask.cdap.messaging.store that return types with arguments of type PayloadTable.Entry

Modifier and Type	Method and Description
co.cask.cdap.api.dataset.lib.CloseableIterator<PayloadTable.Entry>	PayloadTable.fetch(TopicMetadata metadata, long transactionWritePointer, MessageId messageId, boolean inclusive, int limit) Fetches entries from the payload table under the given topic, starting from the given MessageId.
co.cask.cdap.api.dataset.lib.CloseableIterator<PayloadTable.Entry>	AbstractPayloadTable.fetch(TopicMetadata metadata, long transactionWritePointer, MessageId messageId, boolean inclusive, int limit)

Method parameters in co.cask.cdap.messaging.store with type arguments of type PayloadTable.Entry

Modifier and Type	Method and Description
void	PayloadTable.store(Iterator<? extends PayloadTable.Entry> entries) Stores a list of entries to the payload table under the given topic.
void	AbstractPayloadTable.store(Iterator<? extends PayloadTable.Entry> entries)