Uses of Class
co.cask.cdap.messaging.TopicMetadata

Packages that use TopicMetadata

Package	Description
co.cask.cdap.messaging
co.cask.cdap.messaging.client
co.cask.cdap.messaging.distributed
co.cask.cdap.messaging.service
co.cask.cdap.messaging.store
co.cask.cdap.messaging.store.hbase
co.cask.cdap.messaging.store.leveldb

Uses of TopicMetadata in co.cask.cdap.messaging

Methods in co.cask.cdap.messaging that return TopicMetadata

Modifier and Type	Method and Description
TopicMetadata	MessagingService.getTopic(co.cask.cdap.proto.id.TopicId topicId) Returns the metadata of the given topic.

Methods in co.cask.cdap.messaging with parameters of type TopicMetadata

Modifier and Type	Method and Description
void	MessagingService.createTopic(TopicMetadata topicMetadata) Creates a topic with the given metadata.
static void	MessagingServices.createTopicIfNotExists(MessagingService messagingService, TopicMetadata topicMetadata)
void	MessagingService.updateTopic(TopicMetadata topicMetadata) Updates the metadata of a topic.

Uses of TopicMetadata in co.cask.cdap.messaging.client

Methods in co.cask.cdap.messaging.client that return TopicMetadata

Modifier and Type	Method and Description
TopicMetadata	ClientMessagingService.getTopic(co.cask.cdap.proto.id.TopicId topicId)

Methods in co.cask.cdap.messaging.client with parameters of type TopicMetadata

Modifier and Type	Method and Description
void	ClientMessagingService.createTopic(TopicMetadata topicMetadata)
void	ClientMessagingService.updateTopic(TopicMetadata topicMetadata)

Uses of TopicMetadata in co.cask.cdap.messaging.distributed

Methods in co.cask.cdap.messaging.distributed that return TopicMetadata

Modifier and Type	Method and Description
TopicMetadata	LeaderElectionMessagingService.getTopic(co.cask.cdap.proto.id.TopicId topicId)

Methods in co.cask.cdap.messaging.distributed with parameters of type TopicMetadata

Modifier and Type	Method and Description
void	LeaderElectionMessagingService.createTopic(TopicMetadata topicMetadata)
void	LeaderElectionMessagingService.updateTopic(TopicMetadata topicMetadata)

Uses of TopicMetadata in co.cask.cdap.messaging.service

Methods in co.cask.cdap.messaging.service that return TopicMetadata

Modifier and Type	Method and Description
TopicMetadata	CoreMessagingService.getTopic(co.cask.cdap.proto.id.TopicId topicId)

Methods in co.cask.cdap.messaging.service with parameters of type TopicMetadata

Modifier and Type	Method and Description
void	CoreMessagingService.createTopic(TopicMetadata topicMetadata)
void	CoreMessagingService.updateTopic(TopicMetadata topicMetadata)

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

Methods in co.cask.cdap.messaging.store that return TopicMetadata

Modifier and Type	Method and Description
TopicMetadata	MetadataTable.getMetadata(co.cask.cdap.proto.id.TopicId topicId) Fetch the metadata of the TopicId.

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

Modifier and Type	Method and Description
void	MetadataTable.createTopic(TopicMetadata topicMetadata) Create a topic with properties.
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<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.
void	AbstractMessageTable.rollback(TopicMetadata metadata, RollbackDetail rollbackDetail)
void	MessageTable.rollback(TopicMetadata metadata, RollbackDetail rollbackDetail) Rollback entries stored earlier, as deleted, under the given topic based on the given information.
void	MetadataTable.updateTopic(TopicMetadata topicMetadata) Updates the topic properties.

Uses of TopicMetadata in co.cask.cdap.messaging.store.hbase

Methods in co.cask.cdap.messaging.store.hbase that return TopicMetadata

Modifier and Type	Method and Description
TopicMetadata	HBaseMetadataTable.getMetadata(co.cask.cdap.proto.id.TopicId topicId)

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

Modifier and Type	Method and Description
void	HBaseMetadataTable.createTopic(TopicMetadata topicMetadata)
void	HBaseMetadataTable.updateTopic(TopicMetadata topicMetadata)

Uses of TopicMetadata in co.cask.cdap.messaging.store.leveldb

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

Modifier and Type	Method and Description
void	LevelDBPayloadTable.pruneMessages(TopicMetadata topicMetadata, long currentTime) Delete messages of a TopicId that has exceeded the TTL or if it belongs to an older generation