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

Packages that use CatalogTable

Package	Description
org.apache.flink.connectors.hive
org.apache.flink.connectors.hive.read
org.apache.flink.table.catalog
org.apache.flink.table.factories
org.apache.flink.table.operations.ddl

Uses of CatalogTable in org.apache.flink.connectors.hive

Methods in org.apache.flink.connectors.hive with parameters of type CatalogTable

Modifier and Type	Method and Description
TableSink<Row>	HiveTableFactory.createTableSink(ObjectPath tablePath, CatalogTable table)
TableSource<BaseRow>	HiveTableFactory.createTableSource(ObjectPath tablePath, CatalogTable table)

Constructors in org.apache.flink.connectors.hive with parameters of type CatalogTable

Constructor and Description
HiveTableSink(org.apache.hadoop.mapred.JobConf jobConf, ObjectPath tablePath, CatalogTable table)
HiveTableSource(org.apache.hadoop.mapred.JobConf jobConf, ObjectPath tablePath, CatalogTable catalogTable)

Uses of CatalogTable in org.apache.flink.connectors.hive.read

Constructors in org.apache.flink.connectors.hive.read with parameters of type CatalogTable

Constructor and Description
HiveTableInputFormat(org.apache.hadoop.mapred.JobConf jobConf, CatalogTable catalogTable, List<HiveTablePartition> partitions, int[] projectedFields, long limit, String hiveVersion, boolean useMapRedReader)

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

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

Modifier and Type	Class and Description
class	AbstractCatalogTable An abstract catalog table.
class	CatalogTableImpl A catalog table implementation.
class	ConnectorCatalogTable<T1,T2> A CatalogTable that wraps a TableSource and/or TableSink.

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

Modifier and Type	Method and Description
CatalogTable	CatalogTableBuilder.build() Builds a CatalogTable.

Uses of CatalogTable in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories with parameters of type CatalogTable

Modifier and Type	Method and Description
default TableSink<T>	TableSinkFactory.createTableSink(ObjectPath tablePath, CatalogTable table) Creates and configures a TableSink based on the given CatalogTable instance.
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.
default TableSource<T>	TableSourceFactory.createTableSource(ObjectPath tablePath, CatalogTable table) Creates and configures a TableSource based on the given CatalogTable instance.
static <T> TableSink<T>	TableFactoryUtil.findAndCreateTableSink(CatalogTable table) Returns a table sink matching the CatalogTable.
static <T> TableSource<T>	TableFactoryUtil.findAndCreateTableSource(CatalogTable table) Returns a table source matching the CatalogTable.

Uses of CatalogTable in org.apache.flink.table.operations.ddl

Methods in org.apache.flink.table.operations.ddl that return CatalogTable

Modifier and Type	Method and Description
CatalogTable	CreateTableOperation.getCatalogTable()
CatalogTable	AlterTablePropertiesOperation.getCatalogTable()

Constructors in org.apache.flink.table.operations.ddl with parameters of type CatalogTable

Constructor and Description
AlterTablePropertiesOperation(ObjectIdentifier tableIdentifier, CatalogTable catalogTable)
CreateTableOperation(ObjectIdentifier tableIdentifier, CatalogTable catalogTable, boolean ignoreIfExists)