org.apache.flink.table.catalog

Class CatalogManagerCalciteSchema

java.lang.Object

org.apache.flink.table.catalog.CatalogManagerCalciteSchema

All Implemented Interfaces:

org.apache.calcite.schema.Schema

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

Bridge between the CatalogManager and the Schema. This way we can query Flink's specific catalogs from Calcite.

The mapping for Catalogs is modeled as a strict two-level reference structure for Flink in Calcite, the full path of objects is of format [catalog_name].[db_name].[meta-object_name].

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
CatalogManagerCalciteSchema(org.apache.flink.table.catalog.CatalogManager catalogManager, boolean isStreamingMode)

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 name)
org.apache.calcite.schema.Schema	getSubSchema(String 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 version)

Methods inherited from class java.lang.Object

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

Constructor Detail

CatalogManagerCalciteSchema

public CatalogManagerCalciteSchema(org.apache.flink.table.catalog.CatalogManager catalogManager,
                                   boolean isStreamingMode)

Method Detail

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 name)

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

getSubSchema

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

Specified by:

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

getSubSchemaNames

public Set<String> getSubSchemaNames()

Specified by:

getSubSchemaNames 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 version)

Specified by:

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