co.cask.cdap.messaging.store

Class ForwardingTableFactory

java.lang.Object

co.cask.cdap.messaging.store.ForwardingTableFactory

All Implemented Interfaces:

TableFactory

Direct Known Subclasses:

CachingTableFactory

public abstract class ForwardingTableFactory
extends Object
implements TableFactory

A TableFactory that forwards all operations to another TableFactory.

Constructor Summary

Constructors

Constructor and Description
ForwardingTableFactory()

Method Summary

Modifier and Type	Method and Description
MessageTable	createMessageTable(String tableName)
MetadataTable	createMetadataTable(String tableName)
PayloadTable	createPayloadTable(String tableName)
abstract TableFactory	getDelegate() Returns the TableFactory that this class forwards to.

Methods inherited from class java.lang.Object

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

Constructor Detail

ForwardingTableFactory

public ForwardingTableFactory()

Method Detail

getDelegate

public abstract TableFactory getDelegate()

Returns the TableFactory that this class forwards to.

createMetadataTable

public MetadataTable createMetadataTable(String tableName)
                                  throws IOException

Specified by:

createMetadataTable in interface TableFactory

Throws:

IOException

createMessageTable

public MessageTable createMessageTable(String tableName)
                                throws IOException

Specified by:

createMessageTable in interface TableFactory

Throws:

IOException

createPayloadTable

public PayloadTable createPayloadTable(String tableName)
                                throws IOException

Specified by:

createPayloadTable in interface TableFactory

Throws:

IOException