Package | Description |
---|---|
org.apache.flink.connectors.hive | |
org.apache.flink.table.catalog | |
org.apache.flink.table.factories | |
org.apache.flink.table.operations.ddl |
Modifier and Type | Method and Description |
---|---|
TableSink<Row> |
HiveTableFactory.createTableSink(ObjectPath tablePath,
CatalogTable table) |
TableSource<Row> |
HiveTableFactory.createTableSource(ObjectPath tablePath,
CatalogTable table) |
Constructor and Description |
---|
HiveTableInputFormat(org.apache.hadoop.mapred.JobConf jobConf,
CatalogTable catalogTable,
List<HiveTablePartition> partitions) |
HiveTableOutputFormat(org.apache.hadoop.mapred.JobConf jobConf,
ObjectPath tablePath,
CatalogTable table,
HiveTablePartition hiveTablePartition,
Properties tableProperties,
boolean overwrite) |
HiveTableSink(org.apache.hadoop.mapred.JobConf jobConf,
ObjectPath tablePath,
CatalogTable table) |
HiveTableSource(org.apache.hadoop.mapred.JobConf jobConf,
ObjectPath tablePath,
CatalogTable catalogTable) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCatalogTable
An abstract catalog table.
|
class |
CatalogTableImpl
A catalog table implementation.
|
class |
ConnectorCatalogTable<T1,T2>
|
Modifier and Type | Method and Description |
---|---|
CatalogTable |
CatalogTableBuilder.build()
Builds a
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 sink matching the
CatalogTable . |
Modifier and Type | Method and Description |
---|---|
CatalogTable |
CreateTableOperation.getCatalogTable() |
Constructor and Description |
---|
CreateTableOperation(String[] tablePath,
CatalogTable catalogTable,
boolean ignoreIfExists) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.