co.cask.cdap.messaging.store.leveldb

Class LevelDBTableFactory

java.lang.Object

co.cask.cdap.messaging.store.leveldb.LevelDBTableFactory

All Implemented Interfaces:

TableFactory

public final class LevelDBTableFactory
extends Object
implements TableFactory

A TableFactory for creating tables used by the messaging system using the LevelDB implementation.

Constructor Summary

Constructors

Constructor and Description
LevelDBTableFactory(CConfiguration cConf)

Method Summary

Modifier and Type	Method and Description
MessageTable	createMessageTable(String tableName)
MetadataTable	createMetadataTable(String tableName)
PayloadTable	createPayloadTable(String tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

LevelDBTableFactory

@Inject
public LevelDBTableFactory(CConfiguration cConf)

Method Detail

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