Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.catalog |
Modifier and Type | Method and Description |
---|---|
ExternalCatalog |
TableEnvironment.getRegisteredExternalCatalog(String name)
Gets a registered
ExternalCatalog by name. |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironment.registerExternalCatalog(String name,
ExternalCatalog externalCatalog)
Registers an
ExternalCatalog under a unique name in the TableEnvironment's schema. |
Modifier and Type | Interface and Description |
---|---|
interface |
CrudExternalCatalog
The CrudExternalCatalog provides methods to create, drop, and alter (sub-)catalogs or tables.
|
Modifier and Type | Class and Description |
---|---|
class |
InMemoryExternalCatalog
This class is an in-memory implementation of
ExternalCatalog . |
Modifier and Type | Method and Description |
---|---|
ExternalCatalog |
InMemoryExternalCatalog.getSubCatalog(String catalogName) |
ExternalCatalog |
ExternalCatalog.getSubCatalog(String dbName)
Gets a sub catalog from this catalog.
|
Modifier and Type | Method and Description |
---|---|
void |
InMemoryExternalCatalog.alterSubCatalog(String catalogName,
ExternalCatalog catalog,
boolean ignoreIfNotExists) |
void |
CrudExternalCatalog.alterSubCatalog(String name,
ExternalCatalog catalog,
boolean ignoreIfNotExists)
Modifies an existing sub catalog of this catalog.
|
void |
InMemoryExternalCatalog.createSubCatalog(String catalogName,
ExternalCatalog catalog,
boolean ignoreIfExists) |
void |
CrudExternalCatalog.createSubCatalog(String name,
ExternalCatalog catalog,
boolean ignoreIfExists)
Adds a subcatalog to this catalog.
|
static void |
ExternalCatalogSchema.registerCatalog(org.apache.calcite.schema.SchemaPlus parentSchema,
String externalCatalogIdentifier,
ExternalCatalog externalCatalog)
Registers an external catalog in a Calcite schema.
|
void |
ExternalCatalogSchema$.registerCatalog(org.apache.calcite.schema.SchemaPlus parentSchema,
String externalCatalogIdentifier,
ExternalCatalog externalCatalog)
Registers an external catalog in a Calcite schema.
|
Constructor and Description |
---|
ExternalCatalogSchema(String catalogIdentifier,
ExternalCatalog catalog) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.