Constructor and Description |
---|
HiveTableSink(boolean userMrWriter,
boolean isBounded,
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 |
---|
HiveContinuousMonitoringFunction(HiveShim hiveShim,
org.apache.hadoop.mapred.JobConf conf,
ObjectPath tablePath,
CatalogTable catalogTable,
int readerParallelism,
ConsumeOrder consumeOrder,
String consumeOffset,
String extractorKind,
String extractorClass,
String extractorPattern,
long interval) |
HiveTableInputFormat(org.apache.hadoop.mapred.JobConf jobConf,
CatalogTable catalogTable,
List<HiveTablePartition> partitions,
int[] projectedFields,
long limit,
String hiveVersion,
boolean useMapRedReader) |
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) |
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)
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)
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)
Creates a
TableSink from a CatalogTable . |
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration)
Creates a
TableSource from a CatalogTable . |
Constructor and Description |
---|
TableSinkFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isBounded) |
TableSourceFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config) |
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) |
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.