Modifier and Type | Field and Description |
---|---|
protected CatalogTable |
HiveTableSource.catalogTable |
Constructor and Description |
---|
HiveLookupTableSource(org.apache.hadoop.mapred.JobConf jobConf,
ReadableConfig flinkConf,
ObjectPath tablePath,
CatalogTable catalogTable) |
HiveTableSink(ReadableConfig flinkConf,
org.apache.hadoop.mapred.JobConf jobConf,
ObjectIdentifier identifier,
CatalogTable table) |
HiveTableSource(org.apache.hadoop.mapred.JobConf jobConf,
ReadableConfig flinkConf,
ObjectPath tablePath,
CatalogTable catalogTable) |
Constructor and Description |
---|
HiveCompactReaderFactory(org.apache.hadoop.hive.metastore.api.StorageDescriptor sd,
Properties properties,
org.apache.hadoop.mapred.JobConf jobConf,
CatalogTable catalogTable,
String hiveVersion,
RowType producedRowType,
boolean useMapRedReader) |
Modifier and Type | Method and Description |
---|---|
static List<HiveTablePartition> |
HivePartitionUtils.getAllPartitions(org.apache.hadoop.mapred.JobConf jobConf,
String hiveVersion,
ObjectPath tablePath,
CatalogTable catalogTable,
HiveShim hiveShim,
List<Map<String,String>> remainingPartitions)
Returns all HiveTablePartitions of a hive table, returns single HiveTablePartition if the
hive table is not partitioned.
|
Modifier and Type | Method and Description |
---|---|
static KinesisPartitioner<RowData> |
KinesisOptions.getKinesisPartitioner(ReadableConfig tableOptions,
CatalogTable targetTable,
ClassLoader classLoader)
Constructs the kinesis partitioner for a
targetTable based on the currently set
tableOptions . |
static void |
KinesisDynamicTableFactory.validateKinesisPartitioner(ReadableConfig tableOptions,
CatalogTable targetTable) |
Constructor and Description |
---|
RowDataFieldsKinesisPartitioner(CatalogTable table) |
RowDataFieldsKinesisPartitioner(CatalogTable table,
String delimiter) |
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 . |
CatalogTable |
ConnectorCatalogTable.copy(Map<String,String> options) |
CatalogTable |
CatalogTableImpl.copy(Map<String,String> options) |
CatalogTable |
CatalogTable.copy(Map<String,String> options)
Returns a copy of this
CatalogTable with given table options options . |
Modifier and Type | Method and Description |
---|---|
static void |
HiveTableUtil.alterColumns(org.apache.hadoop.hive.metastore.api.StorageDescriptor sd,
CatalogTable catalogTable) |
static void |
HiveTableUtil.checkAcidTable(CatalogTable catalogTable,
ObjectPath tablePath)
Check whether to read or write on the hive ACID table.
|
Modifier and Type | Method and Description |
---|---|
CatalogTable |
DynamicTableFactory.Context.getCatalogTable()
Returns table information received from the
Catalog . |
CatalogTable |
TableSinkFactoryContextImpl.getTable() |
CatalogTable |
TableSinkFactory.Context.getTable() |
CatalogTable |
TableSourceFactoryContextImpl.getTable() |
CatalogTable |
TableSourceFactory.Context.getTable() |
Modifier and Type | Method and Description |
---|---|
static DynamicTableSink |
FactoryUtil.createTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
default TableSink<T> |
TableSinkFactory.createTableSink(ObjectPath tablePath,
CatalogTable table)
Deprecated.
TableSinkFactory.Context contains more information, and already contains table schema too.
Please use TableSinkFactory.createTableSink(Context) instead. |
static DynamicTableSource |
FactoryUtil.createTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSource from a CatalogTable . |
default TableSource<T> |
TableSourceFactory.createTableSource(ObjectPath tablePath,
CatalogTable table)
Deprecated.
TableSourceFactory.Context contains more information, and already contains table schema too.
Please use TableSourceFactory.createTableSource(Context) instead. |
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 . |
Constructor and Description |
---|
TableSinkFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isBounded,
boolean isTemporary) |
TableSourceFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isTemporary) |
Modifier and Type | Method and Description |
---|---|
CatalogTable |
AlterTableSchemaOperation.getCatalogTable() |
CatalogTable |
CreateTableOperation.getCatalogTable() |
CatalogTable |
AlterTablePropertiesOperation.getCatalogTable() |
Constructor and Description |
---|
AlterTablePropertiesOperation(ObjectIdentifier tableIdentifier,
CatalogTable catalogTable) |
AlterTableSchemaOperation(ObjectIdentifier tableIdentifier,
CatalogTable catalogTable) |
CreateTableOperation(ObjectIdentifier tableIdentifier,
CatalogTable catalogTable,
boolean ignoreIfExists,
boolean isTemporary) |
Constructor and Description |
---|
CatalogSourceTable(org.apache.calcite.plan.RelOptSchema relOptSchema,
List<String> names,
org.apache.calcite.rel.type.RelDataType rowType,
CatalogSchemaTable schemaTable,
CatalogTable catalogTable) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.toRel(org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
CatalogSinkModifyOperation sinkOperation,
DynamicTableSink sink,
CatalogTable table)
Similar to
CatalogSourceTable.toRel(RelOptTable.ToRelContext) , converts a given
DynamicTableSink to a RelNode . |
Modifier and Type | Method and Description |
---|---|
static boolean |
DynamicSourceUtils.isSourceChangeEventsDuplicate(CatalogTable catalogTable,
DynamicTableSource tableSource,
TableConfig config)
Returns true if the table source produces duplicate change events.
|
static boolean |
DynamicSourceUtils.isUpsertSource(CatalogTable catalogTable,
DynamicTableSource tableSource)
Returns true if the table is an upsert source.
|
static void |
DynamicSourceUtils.prepareDynamicSource(ObjectIdentifier sourceIdentifier,
CatalogTable table,
DynamicTableSource source,
boolean isStreamingMode,
TableConfig config)
Prepares the given
DynamicTableSource . |
Modifier and Type | Method and Description |
---|---|
static Operation |
OperationConverterUtils.convertAddReplaceColumns(ObjectIdentifier tableIdentifier,
SqlAddReplaceColumns addReplaceColumns,
CatalogTable catalogTable,
org.apache.calcite.sql.validate.SqlValidator sqlValidator) |
static Operation |
OperationConverterUtils.convertChangeColumn(ObjectIdentifier tableIdentifier,
SqlChangeColumn changeColumn,
CatalogTable catalogTable,
org.apache.calcite.sql.validate.SqlValidator sqlValidator) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.