org.apache.beam.sdk.extensions.sql.meta.store

Class InMemoryMetaStore

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

All Implemented Interfaces:

MetaStore

public class InMemoryMetaStore
extends java.lang.Object
implements MetaStore

A MetaStore which stores the meta info in memory.

NOTE, because this implementation is memory based, the metadata is NOT persistent. for tables which created, you need to create again every time you launch the BeamSqlCli.

Constructor Summary

Constructors

Constructor and Description
InMemoryMetaStore()

Method Summary

Modifier and Type	Method and Description
BeamSqlTable	buildBeamSqlTable(java.lang.String tableName) Build the BeamSqlTable for the specified table.
void	createTable(Table table) create a table.
void	dropTable(java.lang.String tableName) drop a table.
Table	getTable(java.lang.String tableName) Get table with the specified name.
java.util.List<Table>	listTables() List all the tables.
void	registerProvider(TableProvider provider) Register a table provider.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryMetaStore

public InMemoryMetaStore()

Method Detail

createTable

public void createTable(Table table)

Description copied from interface: MetaStore

create a table.

Specified by:

createTable in interface MetaStore

dropTable

public void dropTable(java.lang.String tableName)

Description copied from interface: MetaStore

drop a table.

Specified by:

dropTable in interface MetaStore

getTable

public Table getTable(java.lang.String tableName)

Description copied from interface: MetaStore

Get table with the specified name.

Specified by:

getTable in interface MetaStore

listTables

public java.util.List<Table> listTables()

Description copied from interface: MetaStore

List all the tables.

Specified by:

listTables in interface MetaStore

buildBeamSqlTable

public BeamSqlTable buildBeamSqlTable(java.lang.String tableName)

Description copied from interface: MetaStore

Build the BeamSqlTable for the specified table.

Specified by:

buildBeamSqlTable in interface MetaStore

registerProvider

public void registerProvider(TableProvider provider)

Description copied from interface: MetaStore

Register a table provider.

Specified by:

registerProvider in interface MetaStore