Uses of Class
co.cask.cdap.messaging.data.MessageId

Packages that use MessageId

Package	Description
co.cask.cdap.messaging.store

Uses of MessageId in co.cask.cdap.messaging.store

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

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)
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.