co.cask.cdap.messaging.store.hbase

Class HBaseMetadataTable

java.lang.Object

co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

All Implemented Interfaces:

MetadataTable, Closeable, AutoCloseable

public final class HBaseMetadataTable
extends Object
implements MetadataTable

HBase implementation of MetadataTable.

Field Summary

Fields

Modifier and Type	Field and Description
static byte[]	COL

Method Summary

Modifier and Type	Method and Description
void	close()
void	createTopic(TopicMetadata topicMetadata) Create a topic with properties.
void	deleteTopic(co.cask.cdap.proto.id.TopicId topicId) Delete a topic.
TopicMetadata	getMetadata(co.cask.cdap.proto.id.TopicId topicId) Fetch the metadata of the TopicId.
List<co.cask.cdap.proto.id.TopicId>	listTopics() List all topics in the messaging system.
List<co.cask.cdap.proto.id.TopicId>	listTopics(co.cask.cdap.proto.id.NamespaceId namespaceId) List all the topics in a namespace.
void	updateTopic(TopicMetadata topicMetadata) Updates the topic properties.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

COL

public static final byte[] COL

Method Detail

getMetadata

public TopicMetadata getMetadata(co.cask.cdap.proto.id.TopicId topicId)
                          throws IOException,
                                 co.cask.cdap.api.messaging.TopicNotFoundException

Description copied from interface: MetadataTable

Fetch the metadata of the TopicId.

Specified by:

getMetadata in interface MetadataTable

Parameters:

topicId - message topic

Returns:

metadata of the TopicId

Throws:

IOException - if failed to retrieve metadata

co.cask.cdap.api.messaging.TopicNotFoundException - if the topic doesn't exist

createTopic

public void createTopic(TopicMetadata topicMetadata)
                 throws co.cask.cdap.api.messaging.TopicAlreadyExistsException,
                        IOException

Description copied from interface: MetadataTable

Create a topic with properties.

Specified by:

createTopic in interface MetadataTable

Parameters:

topicMetadata - metadata of the topic

Throws:

co.cask.cdap.api.messaging.TopicAlreadyExistsException - if the topic already exist

IOException - if failed to create topic

updateTopic

public void updateTopic(TopicMetadata topicMetadata)
                 throws co.cask.cdap.api.messaging.TopicNotFoundException,
                        IOException

Description copied from interface: MetadataTable

Updates the topic properties.

Specified by:

updateTopic in interface MetadataTable

Parameters:

topicMetadata - metadata of the topic.

Throws:

co.cask.cdap.api.messaging.TopicNotFoundException - if the topic doesn't exist

IOException - if failed to update metadata

deleteTopic

public void deleteTopic(co.cask.cdap.proto.id.TopicId topicId)
                 throws co.cask.cdap.api.messaging.TopicNotFoundException,
                        IOException

Description copied from interface: MetadataTable

Delete a topic.

Specified by:

deleteTopic in interface MetadataTable

Parameters:

topicId - message topic

Throws:

co.cask.cdap.api.messaging.TopicNotFoundException - if the topic doesn't exist

IOException - if failed to delete the topic

listTopics

public List<co.cask.cdap.proto.id.TopicId> listTopics(co.cask.cdap.proto.id.NamespaceId namespaceId)
                                               throws IOException

Description copied from interface: MetadataTable

List all the topics in a namespace.

Specified by:

listTopics in interface MetadataTable

Parameters:

namespaceId - namespace

Returns:

List of topics in that namespace

Throws:

IOException - if failed to retrieve topics

listTopics

public List<co.cask.cdap.proto.id.TopicId> listTopics()
                                               throws IOException

Description copied from interface: MetadataTable

List all topics in the messaging system.

Specified by:

listTopics in interface MetadataTable

Returns:

List of all topics.

Throws:

IOException - if failed to retrieve topics

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException