public class InMemoryMetaStore extends java.lang.Object implements MetaStore
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 and Description |
---|
InMemoryMetaStore() |
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.
|
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.
|
public void createTable(Table table)
MetaStore
createTable
in interface MetaStore
public Table getTable(java.lang.String tableName)
MetaStore
public java.util.List<Table> listTables()
MetaStore
listTables
in interface MetaStore
public BeamSqlTable buildBeamSqlTable(java.lang.String tableName)
MetaStore
BeamSqlTable
for the specified table.buildBeamSqlTable
in interface MetaStore
public void registerProvider(TableProvider provider)
MetaStore
registerProvider
in interface MetaStore