Package org.apache.beam.sdk.extensions.sql.impl

Class CatalogSchema

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.CatalogSchema

All Implemented Interfaces:

org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

public class CatalogSchema
extends Object
implements org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

A Calcite Schema that corresponds to a Catalog. Child schemas are of type BeamCalciteSchema.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema.TableType

Method Summary

Modifier and Type	Method	Description
void	createDatabase(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier databaseIdentifier, boolean ifNotExists)
void	dropDatabase(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier, boolean cascade, boolean ifExists)
Catalog	getCatalog()
@Nullable BeamCalciteSchema	getCurrentDatabaseSchema()
BeamCalciteSchema	getDatabaseSchema(TableName tablePath)
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.linq4j.tree.Expression	getExpression(@Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaPlus schemaPlus, String s)
Set<String>	getFunctionNames()
Collection<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Function>	getFunctions(String s)
@Nullable BeamCalciteSchema	getSubSchema(@Nullable String name)
Set<String>	getSubSchemaNames()
@Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Table	getTable(String s)
Set<String>	getTableNames()
@Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.type.RelProtoDataType	getType(String s)
Set<String>	getTypeNames()
boolean	isMutable()
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema	snapshot(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaVersion schemaVersion)
void	useDatabase(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier)

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.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

subSchemas, tables

Method Details

getCatalog

public Catalog getCatalog()

getCurrentDatabaseSchema

public @Nullable BeamCalciteSchema getCurrentDatabaseSchema()

getDatabaseSchema

public BeamCalciteSchema getDatabaseSchema(TableName tablePath)

createDatabase

public void createDatabase(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier databaseIdentifier,
 boolean ifNotExists)

useDatabase

public void useDatabase(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier)

dropDatabase

public void dropDatabase(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier,
 boolean cascade,
 boolean ifExists)

getTable

public @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Table getTable(String s)

Specified by:

getTable in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

getTableNames

public Set<String> getTableNames()

Specified by:

getTableNames in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

getSubSchema

public @Nullable BeamCalciteSchema getSubSchema(@Nullable String name)

Specified by:

getSubSchema in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

getSubSchemaNames

public Set<String> getSubSchemaNames()

Specified by:

getSubSchemaNames in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

getTypeNames

public Set<String> getTypeNames()

Specified by:

getTypeNames in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

getType

public @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.type.RelProtoDataType getType(String s)

Specified by:

getType in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

getFunctions

public Collection<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Function> getFunctions(String s)

Specified by:

getFunctions in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

getFunctionNames

public Set<String> getFunctionNames()

Specified by:

getFunctionNames in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

getExpression

public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.linq4j.tree.Expression getExpression(@Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaPlus schemaPlus,
 String s)

Specified by:

getExpression in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

isMutable

public boolean isMutable()

Specified by:

isMutable in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

snapshot

public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema snapshot(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaVersion schemaVersion)

Specified by:

snapshot in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema