@Internal public class CatalogManagerCalciteSchema extends Object implements org.apache.calcite.schema.Schema
CatalogManager
and the Schema
. This way we can query Flink's specific catalogs
from Calcite.
The mapping for Catalog
s 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].
It also supports ExternalCatalog
s. An external catalog maps 1:1 to the Calcite's schema.
Constructor and Description |
---|
CatalogManagerCalciteSchema(CatalogManager catalogManager,
boolean isStreamingMode) |
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) |
public CatalogManagerCalciteSchema(CatalogManager catalogManager, boolean isStreamingMode)
public org.apache.calcite.schema.Table getTable(String name)
getTable
in interface org.apache.calcite.schema.Schema
public Set<String> getTableNames()
getTableNames
in interface org.apache.calcite.schema.Schema
public org.apache.calcite.rel.type.RelProtoDataType getType(String name)
getType
in interface org.apache.calcite.schema.Schema
public Set<String> getTypeNames()
getTypeNames
in interface org.apache.calcite.schema.Schema
public Collection<org.apache.calcite.schema.Function> getFunctions(String name)
getFunctions
in interface org.apache.calcite.schema.Schema
public Set<String> getFunctionNames()
getFunctionNames
in interface org.apache.calcite.schema.Schema
public org.apache.calcite.schema.Schema getSubSchema(String name)
getSubSchema
in interface org.apache.calcite.schema.Schema
public Set<String> getSubSchemaNames()
getSubSchemaNames
in interface org.apache.calcite.schema.Schema
public org.apache.calcite.linq4j.tree.Expression getExpression(org.apache.calcite.schema.SchemaPlus parentSchema, String name)
getExpression
in interface org.apache.calcite.schema.Schema
public boolean isMutable()
isMutable
in interface org.apache.calcite.schema.Schema
public org.apache.calcite.schema.Schema snapshot(org.apache.calcite.schema.SchemaVersion version)
snapshot
in interface org.apache.calcite.schema.Schema
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.