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

Packages that use MessageTable.Entry

Package	Description
co.cask.cdap.messaging.store
co.cask.cdap.messaging.store.cache

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

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

Modifier and Type	Class and Description
class	ImmutableMessageTableEntry An immutable implementation of MessageTable.Entry.

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

Modifier and Type	Method and Description
co.cask.cdap.api.dataset.lib.CloseableIterator<MessageTable.Entry>	AbstractMessageTable.fetch(TopicMetadata metadata, long startTime, int limit, org.apache.tephra.Transaction transaction)
co.cask.cdap.api.dataset.lib.CloseableIterator<MessageTable.Entry>	MessageTable.fetch(TopicMetadata metadata, long startTime, int limit, org.apache.tephra.Transaction transaction) Fetches message table entries in the given topic that were publish on or after the given start time.
co.cask.cdap.api.dataset.lib.CloseableIterator<MessageTable.Entry>	AbstractMessageTable.fetch(TopicMetadata metadata, MessageId messageId, boolean inclusive, int limit, org.apache.tephra.Transaction transaction)
co.cask.cdap.api.dataset.lib.CloseableIterator<MessageTable.Entry>	MessageTable.fetch(TopicMetadata metadata, MessageId messageId, boolean inclusive, int limit, org.apache.tephra.Transaction transaction) Fetches message table entries in the given topic, starting from the given MessageId.

Methods in co.cask.cdap.messaging.store with parameters of type MessageTable.Entry

Modifier and Type	Method and Description
MessageFilter.Result	TransactionMessageFilter.apply(MessageTable.Entry entry)

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

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

Uses of MessageTable.Entry in co.cask.cdap.messaging.store.cache

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

Modifier and Type	Method and Description
MessageCache<MessageTable.Entry>	DefaultMessageTableCacheProvider.getMessageCache(co.cask.cdap.proto.id.TopicId topicId)
MessageCache<MessageTable.Entry>	MessageTableCacheProvider.getMessageCache(co.cask.cdap.proto.id.TopicId topicId) Returns a MessageCache for the given topic.