org.apache.flink.table.catalog

Class CatalogCalciteSchema

java.lang.Object

org.apache.flink.table.catalog.CatalogCalciteSchema

All Implemented Interfaces:

org.apache.calcite.schema.Schema

@Internal
public class CatalogCalciteSchema
extends Object
implements org.apache.calcite.schema.Schema

A mapping between Flink's catalog and Calcite's schema. This enables to look up and access objects(tables, views, functions, types) in SQL queries without registering them in advance. Databases are registered as sub-schemas in the schema.

Nested Class Summary

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

org.apache.calcite.schema.Schema.TableType

Constructor Summary

Constructors

Constructor and Description
CatalogCalciteSchema(boolean isStreamingMode, String catalogName, org.apache.flink.table.catalog.CatalogManager catalogManager)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.linq4j.tree.Expression	getExpression(org.apache.calcite.schema.SchemaPlus parentSchema, String name)
Set<String>	getFunctionNames()
Collection<org.apache.calcite.schema.Function>	getFunctions(String s)
org.apache.calcite.schema.Schema	getSubSchema(String schemaName) Look up a sub-schema (database) by the given sub-schema name.
Set<String>	getSubSchemaNames()
org.apache.calcite.schema.Table	getTable(String name)
Set<String>	getTableNames()
org.apache.calcite.rel.type.RelProtoDataType	getType(String name)
Set<String>	getTypeNames()
boolean	isMutable()
org.apache.calcite.schema.Schema	snapshot(org.apache.calcite.schema.SchemaVersion schemaVersion)

Methods inherited from class java.lang.Object

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

Constructor Detail

CatalogCalciteSchema

public CatalogCalciteSchema(boolean isStreamingMode,
                            String catalogName,
                            org.apache.flink.table.catalog.CatalogManager catalogManager)

Method Detail

getSubSchema

public org.apache.calcite.schema.Schema getSubSchema(String schemaName)

Look up a sub-schema (database) by the given sub-schema name.

Specified by:

getSubSchema in interface org.apache.calcite.schema.Schema

Parameters:

schemaName - name of sub-schema to look up

Returns:

the sub-schema with a given database name, or null

getSubSchemaNames

public Set<String> getSubSchemaNames()

Specified by:

getSubSchemaNames in interface org.apache.calcite.schema.Schema

getTable

public org.apache.calcite.schema.Table getTable(String name)

Specified by:

getTable in interface org.apache.calcite.schema.Schema

getTableNames

public Set<String> getTableNames()

Specified by:

getTableNames in interface org.apache.calcite.schema.Schema

getType

public org.apache.calcite.rel.type.RelProtoDataType getType(String name)

Specified by:

getType in interface org.apache.calcite.schema.Schema

getTypeNames

public Set<String> getTypeNames()

Specified by:

getTypeNames in interface org.apache.calcite.schema.Schema

getFunctions

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

Specified by:

getFunctions in interface org.apache.calcite.schema.Schema

getFunctionNames

public Set<String> getFunctionNames()

Specified by:

getFunctionNames in interface org.apache.calcite.schema.Schema

getExpression

public org.apache.calcite.linq4j.tree.Expression getExpression(org.apache.calcite.schema.SchemaPlus parentSchema,
                                                               String name)

Specified by:

getExpression in interface org.apache.calcite.schema.Schema

isMutable

public boolean isMutable()

Specified by:

isMutable in interface org.apache.calcite.schema.Schema

snapshot

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

Specified by:

snapshot in interface org.apache.calcite.schema.Schema