Package org.apache.bookkeeper.metastore

Class InMemoryMetaStore

java.lang.Object

org.apache.bookkeeper.metastore.InMemoryMetaStore

All Implemented Interfaces:

MetaStore

public class InMemoryMetaStore
extends java.lang.Object
implements MetaStore

An in-memory implementation of the MetaStore interface.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static int	CUR_VERSION
(package private) static java.util.Map<java.lang.String,InMemoryMetastoreTable>	tables

Constructor Summary

Constructors

Constructor	Description
InMemoryMetaStore()

Method Summary

Modifier and Type	Method	Description
void	close()	Close the meta store.
MetastoreScannableTable	createScannableTable(java.lang.String name)	Create a scannable metastore table.
MetastoreTable	createTable(java.lang.String name)	Create a metastore table.
java.lang.String	getName()	Return the name of the plugin.
int	getVersion()	Get the plugin verison.
void	init(org.apache.commons.configuration.Configuration conf, int msVersion)	Initialize the meta store.
static void	reset()

Methods inherited from class java.lang.Object

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

Field Detail

CUR_VERSION

static final int CUR_VERSION

See Also:

Constant Field Values

tables

static java.util.Map<java.lang.String,InMemoryMetastoreTable> tables

Constructor Detail

InMemoryMetaStore

public InMemoryMetaStore()

Method Detail

reset

public static void reset()

getName

public java.lang.String getName()

Description copied from interface: MetaStore

Return the name of the plugin.

Specified by:

getName in interface MetaStore

Returns:

the plugin name.

getVersion

public int getVersion()

Description copied from interface: MetaStore

Get the plugin verison.

Specified by:

getVersion in interface MetaStore

Returns:

the plugin version.

init

public void init(org.apache.commons.configuration.Configuration conf,
                 int msVersion)
          throws MetastoreException

Description copied from interface: MetaStore

Initialize the meta store.

Specified by:

init in interface MetaStore

Parameters:

conf - Configuration object passed to metastore

msVersion - Version to initialize the metastore

Throws:

MetastoreException - when failed to initialize

close

public void close()

Description copied from interface: MetaStore

Close the meta store.

Specified by:

close in interface MetaStore

createTable

public MetastoreTable createTable(java.lang.String name)

Description copied from interface: MetaStore

Create a metastore table.

Specified by:

createTable in interface MetaStore

Parameters:

name - Table name.

Returns:

a metastore table

createScannableTable

public MetastoreScannableTable createScannableTable(java.lang.String name)

Description copied from interface: MetaStore

Create a scannable metastore table.

Specified by:

createScannableTable in interface MetaStore

Parameters:

name - Table name.

Returns:

a metastore scannable table