org.apache.beam.sdk.extensions.sql.meta.provider.hcatalog

Class HCatalogTableProvider

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.provider.hcatalog.HCatalogTableProvider

All Implemented Interfaces:

java.io.Serializable, TableProvider

public class HCatalogTableProvider
extends java.lang.Object
implements TableProvider, java.io.Serializable

Table provider that represents a schema stored in Hive Metastore.

Supports only 'db.table' format at the moment, does not support 'catalog.db.table'.

Delegates to sub-providers to get the actual table.

If only the table name is provided, then 'db' is assumed to be 'default'.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
BeamSqlTable	buildBeamSqlTable(Table table) Build a BeamSqlTable using the given table meta info.
static HCatalogTableProvider	create(java.util.Map<java.lang.String,java.lang.String> configuration)
void	createTable(Table table) Creates a table.
void	dropTable(java.lang.String tableName) Drops a table.
TableProvider	getSubProvider(java.lang.String name) Returns a sub-provider, e.g.
java.util.Set<java.lang.String>	getSubProviders() Returns all sub-providers, e.g.
Table	getTable(java.lang.String name) Get a specific table from this provider it is present, or null if it is not present.
java.util.Map<java.lang.String,Table>	getTables() Get all tables from this provider.
java.lang.String	getTableType() Gets the table type this provider handles.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static HCatalogTableProvider create(java.util.Map<java.lang.String,java.lang.String> configuration)

getTableType

public java.lang.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(java.lang.String tableName)

Description copied from interface: TableProvider

Drops a table.

Specified by:

dropTable in interface TableProvider

getTables

public java.util.Map<java.lang.String,Table> getTables()

Description copied from interface: TableProvider

Get all tables from this provider.

Specified by:

getTables in interface TableProvider

getTable

@Nullable
public Table getTable(java.lang.String name)

Description copied from interface: TableProvider

Get a specific table from this provider it is present, or null if it is not present.

Specified by:

getTable 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

getSubProviders

public java.util.Set<java.lang.String> getSubProviders()

Description copied from interface: TableProvider

Returns all sub-providers, e.g. sub-schemas. Temporary, this logic needs to live in BeamCalciteSchema.

Specified by:

getSubProviders in interface TableProvider

getSubProvider

public TableProvider getSubProvider(java.lang.String name)

Description copied from interface: TableProvider

Returns a sub-provider, e.g. sub-schema. Temporary, this logic needs to live in BeamCalciteSchema.

Specified by:

getSubProvider in interface TableProvider