Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
TableEnvironment.getCatalog(String catalogName)
Gets a registered
Catalog by name. |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironment.registerCatalog(String catalogName,
Catalog catalog)
Registers a
Catalog under a unique name. |
Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
TableEnvironmentImpl.getCatalog(String catalogName) |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironmentImpl.registerCatalog(String catalogName,
Catalog catalog) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCatalog
Abstract class for catalogs.
|
class |
GenericInMemoryCatalog
A generic catalog implementation that holds all meta objects in memory.
|
Modifier and Type | Method and Description |
---|---|
Catalog |
GenericInMemoryCatalogFactory.createCatalog(String name,
Map<String,String> properties) |
Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
CatalogManager.getCatalog(String catalogName)
Gets a catalog by name.
|
Modifier and Type | Method and Description |
---|---|
void |
CatalogManager.registerCatalog(String catalogName,
Catalog catalog)
Registers a catalog under the given name.
|
Constructor and Description |
---|
CatalogManager(String defaultCatalogName,
Catalog defaultCatalog) |
Modifier and Type | Class and Description |
---|---|
class |
HiveCatalog
A catalog implementation for Hive.
|
Modifier and Type | Method and Description |
---|---|
Catalog |
HiveCatalogFactory.createCatalog(String name,
Map<String,String> properties) |
Modifier and Type | Method and Description |
---|---|
Map<String,Catalog> |
ExecutionContext.getCatalogs() |
Modifier and Type | Method and Description |
---|---|
Catalog |
CatalogFactory.createCatalog(String name,
Map<String,String> properties)
Creates and configures a
Catalog using the given properties. |
Modifier and Type | Method and Description |
---|---|
static Optional<TableSink> |
TableFactoryUtil.createTableSinkForCatalogTable(Catalog catalog,
CatalogTable catalogTable,
ObjectPath tablePath)
Creates a table sink for a
CatalogTable using table factory associated with the catalog. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.