Modifier and Type | Class and Description |
---|---|
class |
AbstractJdbcCatalog
Abstract catalog for any JDBC catalogs.
|
class |
JdbcCatalog
Catalogs for relational databases via JDBC.
|
class |
MySqlCatalog
Catalog for MySQL.
|
class |
PostgresCatalog
Catalog for PostgreSQL.
|
Modifier and Type | Method and Description |
---|---|
Catalog |
JdbcCatalogFactory.createCatalog(CatalogFactory.Context context) |
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(CatalogFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
ContextResolvedTable.getCatalog()
Returns empty if
ContextResolvedTable.isPermanent() is false. |
Optional<Catalog> |
CatalogManager.getCatalog(String catalogName)
Gets a catalog by name.
|
Modifier and Type | Method and Description |
---|---|
CatalogManager.Builder |
CatalogManager.Builder.defaultCatalog(String defaultCatalogName,
Catalog defaultCatalog) |
static boolean |
ManagedTableListener.isManagedTable(Catalog catalog,
CatalogBaseTable table)
Check a resolved catalog table is Flink's managed table or not.
|
Map<String,String> |
ManagedTableListener.notifyTableCompaction(Catalog catalog,
ObjectIdentifier identifier,
ResolvedCatalogBaseTable<?> table,
CatalogPartitionSpec partitionSpec,
boolean isTemporary)
Notify compaction for managed table.
|
ResolvedCatalogBaseTable<?> |
ManagedTableListener.notifyTableCreation(Catalog catalog,
ObjectIdentifier identifier,
ResolvedCatalogBaseTable<?> table,
boolean isTemporary,
boolean ignoreIfExists)
Notify for creating managed table.
|
void |
ManagedTableListener.notifyTableDrop(Catalog catalog,
ObjectIdentifier identifier,
ResolvedCatalogBaseTable<?> table,
boolean isTemporary,
boolean ignoreIfNotExists)
Notify for dropping managed table.
|
static ContextResolvedTable |
ContextResolvedTable.permanent(ObjectIdentifier identifier,
Catalog catalog,
ResolvedCatalogBaseTable<?> resolvedTable) |
void |
CatalogManager.registerCatalog(String catalogName,
Catalog catalog)
Registers a catalog under the given name.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveCatalog
A catalog implementation for Hive.
|
Modifier and Type | Method and Description |
---|---|
Catalog |
HiveCatalogFactory.createCatalog(CatalogFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
default Catalog |
CatalogFactory.createCatalog(CatalogFactory.Context context)
Creates and configures a
Catalog using the given context. |
default Catalog |
CatalogFactory.createCatalog(String name,
Map<String,String> properties)
Deprecated.
Use
this#createCatalog(Context) instead and implement Factory
instead of TableFactory . |
static Catalog |
FactoryUtil.createCatalog(String catalogName,
Map<String,String> options,
ReadableConfig configuration,
ClassLoader classLoader)
Attempts to discover an appropriate catalog factory and creates an instance of the catalog.
|
Modifier and Type | Method and Description |
---|---|
static DynamicTableSink |
FactoryUtil.createTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
|
static Optional<TableSink> |
TableFactoryUtil.createTableSinkForCatalogTable(Catalog catalog,
TableSinkFactory.Context context)
Creates a table sink for a
CatalogTable using table factory associated with the
catalog. |
static DynamicTableSource |
FactoryUtil.createTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
|
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
boolean isStreamingMode,
boolean isTemporary)
Creates a
TableSink from a CatalogTable . |
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
boolean isTemporary)
Creates a
TableSource from a CatalogTable . |
static boolean |
TableFactoryUtil.isLegacyConnectorOptions(Catalog catalog,
ReadableConfig configuration,
boolean isStreamingMode,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
boolean isTemporary)
Checks whether the
CatalogTable uses legacy connector sink options. |
Modifier and Type | Method and Description |
---|---|
Map<String,Catalog> |
SessionEnvironment.getRegisteredCatalogs() |
Modifier and Type | Method and Description |
---|---|
SessionEnvironment.Builder |
SessionEnvironment.Builder.registerCatalog(String catalogName,
Catalog catalog) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.