public class ExternalCatalogSchema extends Object implements org.apache.calcite.schema.Schema, Logging
param: catalogIdentifier external catalog name param: catalog external catalog
Constructor and Description |
---|
ExternalCatalogSchema(String catalogIdentifier,
ExternalCatalog catalog) |
Modifier and Type | Method and Description |
---|---|
boolean |
contentsHaveChangedSince(long lastCheck,
long now) |
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)
Looks up a sub-schema by the given sub-schema name in the external catalog.
|
Set<String> |
getSubSchemaNames()
Lists the sub-schemas of the external catalog.
|
org.apache.calcite.schema.Table |
getTable(String name)
Looks up and returns a table from this schema.
|
Set<String> |
getTableNames() |
boolean |
isMutable() |
static org.slf4j.Logger |
LOG() |
static void |
registerCatalog(org.apache.calcite.schema.SchemaPlus parentSchema,
String externalCatalogIdentifier,
ExternalCatalog externalCatalog)
Registers an external catalog in a Calcite schema.
|
void |
registerSubSchemas(org.apache.calcite.schema.SchemaPlus plusOfThis)
Registers sub-Schemas to current schema plus
|
public ExternalCatalogSchema(String catalogIdentifier, ExternalCatalog catalog)
public static void registerCatalog(org.apache.calcite.schema.SchemaPlus parentSchema, String externalCatalogIdentifier, ExternalCatalog externalCatalog)
parentSchema
- Parent schema into which the catalog is registeredexternalCatalogIdentifier
- Identifier of the external catalogexternalCatalog
- The external catalog to registerpublic static org.slf4j.Logger LOG()
public org.apache.calcite.schema.Schema getSubSchema(String name)
ExternalCatalogSchema
with the given database name.
getSubSchema
in interface org.apache.calcite.schema.Schema
name
- Name of sub-schema to look up.public Set<String> getSubSchemaNames()
getSubSchemaNames
in interface org.apache.calcite.schema.Schema
public org.apache.calcite.schema.Table getTable(String name)
getTable
in interface org.apache.calcite.schema.Schema
name
- The name of the table to look up.public boolean isMutable()
isMutable
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 org.apache.calcite.linq4j.tree.Expression getExpression(org.apache.calcite.schema.SchemaPlus parentSchema, String name)
getExpression
in interface org.apache.calcite.schema.Schema
public Set<String> getFunctionNames()
getFunctionNames
in interface org.apache.calcite.schema.Schema
public Set<String> getTableNames()
getTableNames
in interface org.apache.calcite.schema.Schema
public boolean contentsHaveChangedSince(long lastCheck, long now)
contentsHaveChangedSince
in interface org.apache.calcite.schema.Schema
public void registerSubSchemas(org.apache.calcite.schema.SchemaPlus plusOfThis)
plusOfThis
- Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.