Package org.apache.bookkeeper.metastore

Class InMemoryMetaStore

java.lang.Object

org.apache.bookkeeper.metastore.InMemoryMetaStore

All Implemented Interfaces:

MetaStore

public class InMemoryMetaStore
extends Object
implements MetaStore

An in-memory implementation of the MetaStore interface.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final int	CUR_VERSION
(package private) static Map<String,InMemoryMetastoreTable>	tables

Constructor Summary

Constructors

Constructor	Description
InMemoryMetaStore()

Method Summary

Modifier and Type	Method	Description
void	close()	Close the meta store.
MetastoreScannableTable	createScannableTable(String name)	Create a scannable metastore table.
MetastoreTable	createTable(String name)	Create a metastore table.
String	getName()	Return the name of the plugin.
int	getVersion()	Get the plugin version.
void	init(org.apache.commons.configuration2.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 Details

CUR_VERSION

static final int CUR_VERSION

See Also:

• Constant Field Values

tables

static Map<String,InMemoryMetastoreTable> tables

Constructor Details

InMemoryMetaStore

public InMemoryMetaStore()

Method Details

reset

public static void reset()

getName

public 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 version.

Specified by:

getVersion in interface MetaStore

Returns:

the plugin version.

init

public void init(org.apache.commons.configuration2.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(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(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