Modifier and Type | Method and Description |
---|---|
CatalogBaseTable |
AbstractJdbcCatalog.getTable(ObjectPath tablePath) |
CatalogBaseTable |
JdbcCatalog.getTable(ObjectPath tablePath) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJdbcCatalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists) |
void |
AbstractJdbcCatalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists) |
Modifier and Type | Method and Description |
---|---|
void |
Registration.createTemporaryTable(String path,
CatalogBaseTable table)
Creates a temporary table in a given path.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ResolvedCatalogBaseTable<T extends CatalogBaseTable>
A common parent that describes the resolved metadata of a table or view in a catalog.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CatalogTable
Represents the unresolved metadata of a table in a
Catalog . |
interface |
CatalogView
Represents the unresolved metadata of a view in a
Catalog . |
interface |
ResolvedCatalogBaseTable<T extends CatalogBaseTable>
A common parent that describes the resolved metadata of a table or view in a catalog.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCatalogTable
An abstract catalog table.
|
class |
AbstractCatalogView
An abstract catalog view.
|
class |
CatalogTableImpl
Deprecated.
Use
CatalogTable.of(Schema, String, List, Map) or a custom implementation
instead. Don't implement against this internal class. It can lead to unintended side effects
if code checks against this class instead of the common interface. |
class |
CatalogViewImpl
Deprecated.
Use
CatalogView.of(Schema, String, String, String, Map) or a custom
implementation instead. Don't implement against this internal class. It can lead to
unintended side effects if code checks against this class instead of the common interface. |
class |
ConnectorCatalogTable<T1,T2>
|
class |
DefaultCatalogTable
Default implementation of a
CatalogTable . |
class |
ExternalCatalogTable
Helper
CatalogTable for representing a table that is backed by some inline connector
(i.e. |
class |
QueryOperationCatalogView
A view created from a
QueryOperation via operations on Table . |
class |
ResolvedCatalogTable
A validated
CatalogTable that is backed by the original metadata coming from the Catalog but resolved by the framework. |
class |
ResolvedCatalogView
A validated
CatalogView that is backed by the original metadata coming from the Catalog but resolved by the framework. |
Modifier and Type | Method and Description |
---|---|
<T extends CatalogBaseTable> |
ContextResolvedTable.getTable()
Returns the original metadata object returned by the catalog.
|
Modifier and Type | Method and Description |
---|---|
CatalogBaseTable |
ExternalCatalogTable.copy() |
CatalogBaseTable |
ConnectorCatalogTable.copy() |
CatalogBaseTable |
CatalogTableImpl.copy()
Deprecated.
|
CatalogBaseTable |
CatalogViewImpl.copy()
Deprecated.
|
CatalogBaseTable |
ResolvedCatalogView.copy() |
CatalogBaseTable |
DefaultCatalogTable.copy() |
CatalogBaseTable |
ResolvedCatalogTable.copy() |
CatalogBaseTable |
CatalogBaseTable.copy()
Get a deep copy of the CatalogBaseTable instance.
|
CatalogBaseTable |
GenericInMemoryCatalog.getTable(ObjectPath tablePath) |
CatalogBaseTable |
Catalog.getTable(ObjectPath tablePath)
|
CatalogBaseTable |
TemporaryOperationListener.onCreateTemporaryTable(ObjectPath tablePath,
CatalogBaseTable table)
This method is called when a temporary table or view is to be created in this catalog.
|
Modifier and Type | Method and Description |
---|---|
void |
CatalogManager.alterTable(CatalogBaseTable table,
ObjectIdentifier objectIdentifier,
boolean ignoreIfNotExists)
Alters a table in a given fully qualified path.
|
void |
GenericInMemoryCatalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists) |
void |
Catalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists)
Modifies an existing table or view.
|
void |
CatalogManager.createTable(CatalogBaseTable table,
ObjectIdentifier objectIdentifier,
boolean ignoreIfExists)
Creates a table in a given fully qualified path.
|
void |
GenericInMemoryCatalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists) |
void |
Catalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists)
Creates a new table or view.
|
void |
CatalogManager.createTemporaryTable(CatalogBaseTable table,
ObjectIdentifier objectIdentifier,
boolean ignoreIfExists)
Creates a temporary table in a given fully qualified path.
|
static boolean |
ManagedTableListener.isManagedTable(Catalog catalog,
CatalogBaseTable table)
Check a resolved catalog table is Flink's managed table or not.
|
CatalogBaseTable |
TemporaryOperationListener.onCreateTemporaryTable(ObjectPath tablePath,
CatalogBaseTable table)
This method is called when a temporary table or view is to be created in this catalog.
|
ResolvedCatalogBaseTable<?> |
CatalogManager.resolveCatalogBaseTable(CatalogBaseTable baseTable)
Resolves a
CatalogBaseTable to a validated ResolvedCatalogBaseTable . |
Modifier and Type | Method and Description |
---|---|
CatalogBaseTable |
HiveCatalog.getTable(ObjectPath tablePath) |
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newCatalogTable,
boolean ignoreIfNotExists) |
void |
HiveCatalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hive.metastore.api.Table |
HiveTableUtil.alterTableViaCatalogBaseTable(ObjectPath tablePath,
CatalogBaseTable baseTable,
org.apache.hadoop.hive.metastore.api.Table oldHiveTable,
HiveConf hiveConf,
boolean managedTable) |
static org.apache.hadoop.hive.metastore.api.Table |
HiveTableUtil.instantiateHiveTable(ObjectPath tablePath,
CatalogBaseTable table,
HiveConf hiveConf,
boolean managedTable) |
Modifier and Type | Field and Description |
---|---|
CatalogBaseTable |
HiveParserBaseSemanticAnalyzer.TableSpec.table |
Modifier and Type | Method and Description |
---|---|
static CatalogBaseTable |
HiveParserBaseSemanticAnalyzer.getCatalogBaseTable(CatalogManager catalogManager,
ObjectIdentifier tableIdentifier) |
CatalogBaseTable |
HiveParserSemanticAnalyzer.getCatalogBaseTable(String tableName,
HiveParserQB qb) |
CatalogBaseTable |
HiveParserSemanticAnalyzer.getCatalogBaseTable(String tableName,
HiveParserQB qb,
boolean throwException) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.