Uses of Interface
org.apache.flink.table.catalog.CatalogBaseTable

Packages that use CatalogBaseTable

Package	Description
org.apache.flink.table.api.internal
org.apache.flink.table.catalog
org.apache.flink.table.catalog.hive
org.apache.flink.table.catalog.listener
org.apache.flink.table.file.testutils.catalog
org.apache.flink.table.planner.delegation.hive.copy

Uses of CatalogBaseTable in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal with parameters of type CatalogBaseTable

Modifier and Type	Method and Description
void	Registration.createTemporaryTable(String path, CatalogBaseTable table) Creates a temporary table in a given path.

Uses of CatalogBaseTable in org.apache.flink.table.catalog

Classes in org.apache.flink.table.catalog with type parameters of type CatalogBaseTable

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.

Subinterfaces of CatalogBaseTable in org.apache.flink.table.catalog

Modifier and Type	Interface and Description
interface	CatalogMaterializedTable Represents the unresolved metadata of a materialized table in a Catalog.
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.

Classes in org.apache.flink.table.catalog that implement CatalogBaseTable

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> A CatalogTable that wraps a TableSource and/or TableSink.
class	DefaultCatalogMaterializedTable Default implementation of a CatalogMaterializedTable.
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	ResolvedCatalogMaterializedTable A validated CatalogMaterializedTable that is backed by the original metadata coming from the Catalog but resolved by the framework.
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.

Methods in org.apache.flink.table.catalog with type parameters of type CatalogBaseTable

Modifier and Type	Method and Description
<T extends CatalogBaseTable> T	ContextResolvedTable.getTable() Returns the original metadata object returned by the catalog.

Methods in org.apache.flink.table.catalog that return CatalogBaseTable

Modifier and Type	Method and Description
CatalogBaseTable	ExternalCatalogTable.copy()
CatalogBaseTable	ConnectorCatalogTable.copy()
CatalogBaseTable	CatalogViewImpl.copy() Deprecated.
CatalogBaseTable	CatalogTableImpl.copy() Deprecated.
CatalogBaseTable	ResolvedCatalogMaterializedTable.copy()
CatalogBaseTable	ResolvedCatalogView.copy()
CatalogBaseTable	CatalogBaseTable.copy() Get a deep copy of the CatalogBaseTable instance.
CatalogBaseTable	DefaultCatalogTable.copy()
CatalogBaseTable	DefaultCatalogMaterializedTable.copy()
CatalogBaseTable	ResolvedCatalogTable.copy()
CatalogBaseTable	GenericInMemoryCatalog.getTable(ObjectPath tablePath)
CatalogBaseTable	Catalog.getTable(ObjectPath tablePath) Returns a CatalogTable or CatalogView identified by the given ObjectPath.
default CatalogBaseTable	Catalog.getTable(ObjectPath tablePath, long timestamp) Returns a CatalogTable or CatalogView at a specific time identified by the given ObjectPath.
CatalogBaseTable	TemporaryOperationListener.onCreateTemporaryTable(ObjectPath tablePath, CatalogBaseTable table) This method is called when a temporary table or view is to be created in this catalog.

Methods in org.apache.flink.table.catalog with parameters of type CatalogBaseTable

Modifier and Type	Method and Description
void	CatalogManager.alterTable(CatalogBaseTable table, List<TableChange> changes, ObjectIdentifier objectIdentifier, boolean ignoreIfNotExists) Alters a table in a given fully qualified path with table changes.
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.
default void	Catalog.alterTable(ObjectPath tablePath, CatalogBaseTable newTable, List<TableChange> tableChanges, 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) Deprecated. 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.

Uses of CatalogBaseTable in org.apache.flink.table.catalog.hive

Methods in org.apache.flink.table.catalog.hive that return CatalogBaseTable

Modifier and Type	Method and Description
CatalogBaseTable	HiveCatalog.getTable(ObjectPath tablePath)

Methods in org.apache.flink.table.catalog.hive with parameters of type CatalogBaseTable

Modifier and Type	Method and Description
void	HiveCatalog.alterTable(ObjectPath tablePath, CatalogBaseTable newCatalogTable, boolean ignoreIfNotExists)
void	HiveCatalog.createTable(ObjectPath tablePath, CatalogBaseTable table, boolean ignoreIfExists)

Uses of CatalogBaseTable in org.apache.flink.table.catalog.listener

Methods in org.apache.flink.table.catalog.listener that return CatalogBaseTable

Modifier and Type	Method and Description
CatalogBaseTable	AlterTableEvent.newTable()
CatalogBaseTable	TableModificationEvent.table()

Methods in org.apache.flink.table.catalog.listener with parameters of type CatalogBaseTable

Modifier and Type	Method and Description
static AlterTableEvent	AlterTableEvent.createEvent(CatalogContext context, ObjectIdentifier identifier, CatalogBaseTable newTable, boolean ignoreIfNotExists)
static DropTableEvent	DropTableEvent.createEvent(CatalogContext context, ObjectIdentifier identifier, CatalogBaseTable table, boolean ignoreIfNotExists, boolean isTemporary)
static CreateTableEvent	CreateTableEvent.createEvent(CatalogContext context, ObjectIdentifier identifier, CatalogBaseTable table, boolean ignoreIfExists, boolean isTemporary)

Uses of CatalogBaseTable in org.apache.flink.table.file.testutils.catalog

Methods in org.apache.flink.table.file.testutils.catalog that return CatalogBaseTable

Modifier and Type	Method and Description
CatalogBaseTable	TestFileSystemCatalog.getTable(ObjectPath tablePath)

Methods in org.apache.flink.table.file.testutils.catalog with parameters of type CatalogBaseTable

Modifier and Type	Method and Description
void	TestFileSystemCatalog.alterTable(ObjectPath tablePath, CatalogBaseTable newTable, boolean ignoreIfNotExists)
void	TestFileSystemCatalog.alterTable(ObjectPath tablePath, CatalogBaseTable newTable, List<TableChange> tableChanges, boolean ignoreIfNotExists)
void	TestFileSystemCatalog.createTable(ObjectPath tablePath, CatalogBaseTable catalogTable, boolean ignoreIfExists)

Uses of CatalogBaseTable in org.apache.flink.table.planner.delegation.hive.copy

Methods in org.apache.flink.table.planner.delegation.hive.copy that return CatalogBaseTable

Modifier and Type	Method and Description
CatalogBaseTable	HiveParserSemanticAnalyzer.getCatalogBaseTable(String tableName, HiveParserQB qb)
CatalogBaseTable	HiveParserSemanticAnalyzer.getCatalogBaseTable(String tableName, HiveParserQB qb, boolean throwException)