Package 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:

TableProvider, MetaStore

Direct Known Subclasses:

IcebergMetastore

public class InMemoryMetaStore
extends 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	Description
InMemoryMetaStore()

Method Summary

Modifier and Type	Method	Description
BeamSqlTable	buildBeamSqlTable(Table table)	Build a BeamSqlTable using the given table meta info.
void	createTable(Table table)	Creates a table.
void	dropTable(String tableName)	Drops a table.
TableProvider	getProvider(String type)	Fetches a TableProvider for this type.
Map<String,Table>	getTables()	Get all tables from this provider.
String	getTableType()	Gets the table type this provider handles.
void	registerProvider(TableProvider provider)	Register a table provider.
boolean	supportsPartitioning(Table table)
Map<String,TableProvider>	tableProviders()	Returns all the registered TableProviders in this MetaStore, organized by type.
protected void	validateTableType(Table table)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider

getSubProvider, getSubProviders, getTable

Constructor Details

InMemoryMetaStore

public InMemoryMetaStore()

Method Details

getTableType

public String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.

Specified by:

getTableType in interface TableProvider

createTable

public void createTable(Table table)

Description copied from interface: TableProvider

Creates a table.

Specified by:

createTable in interface TableProvider

dropTable

public void dropTable(String tableName)

Description copied from interface: TableProvider

Drops a table.

Specified by:

dropTable in interface TableProvider

Parameters:

tableName -

getTables

public Map<String,Table> getTables()

Description copied from interface: TableProvider

Get all tables from this provider.

Specified by:

getTables in interface TableProvider

buildBeamSqlTable

public BeamSqlTable buildBeamSqlTable(Table table)

Description copied from interface: TableProvider

Build a BeamSqlTable using the given table meta info.

Specified by:

buildBeamSqlTable in interface TableProvider

validateTableType

protected void validateTableType(Table table)

registerProvider

public void registerProvider(TableProvider provider)

Description copied from interface: MetaStore

Register a table provider.

Specified by:

registerProvider in interface MetaStore

Parameters:

provider -

tableProviders

public Map<String,TableProvider> tableProviders()

Description copied from interface: MetaStore

Returns all the registered TableProviders in this MetaStore, organized by type.

Specified by:

tableProviders in interface MetaStore

supportsPartitioning

public boolean supportsPartitioning(Table table)

Specified by:

supportsPartitioning in interface TableProvider

getProvider

public TableProvider getProvider(String type)

Fetches a TableProvider for this type. This provider can exist in the current InMemoryMetaStore or a nested InMemoryMetaStore.

Parameters:

type -

Returns: