co.cask.cdap.messaging.store.cache

Class CachingTableFactory

java.lang.Object

co.cask.cdap.messaging.store.ForwardingTableFactory

co.cask.cdap.messaging.store.cache.CachingTableFactory

All Implemented Interfaces:

TableFactory

public class CachingTableFactory
extends ForwardingTableFactory

A TableFactory with optional caching for MessageTable that it creates.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELEGATE_TABLE_FACTORY

Method Summary

Modifier and Type	Method and Description
MessageTable	createMessageTable(String tableName)
MetadataTable	createMetadataTable(String tableName)
PayloadTable	createPayloadTable(String tableName)
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

Field Detail

DELEGATE_TABLE_FACTORY

public static final String DELEGATE_TABLE_FACTORY

See Also:

Constant Field Values

Method Detail

getDelegate

public TableFactory getDelegate()

Description copied from class: ForwardingTableFactory

Returns the TableFactory that this class forwards to.

Specified by:

getDelegate in class ForwardingTableFactory

createMetadataTable

public MetadataTable createMetadataTable(String tableName)
                                  throws IOException

Specified by:

createMetadataTable in interface TableFactory

Overrides:

createMetadataTable in class ForwardingTableFactory

Throws:

IOException

createMessageTable

public MessageTable createMessageTable(String tableName)
                                throws IOException

Specified by:

createMessageTable in interface TableFactory

Overrides:

createMessageTable in class ForwardingTableFactory

Throws:

IOException

createPayloadTable

public PayloadTable createPayloadTable(String tableName)
                                throws IOException

Specified by:

createPayloadTable in interface TableFactory

Overrides:

createPayloadTable in class ForwardingTableFactory

Throws:

IOException