Modifier and Type | Method and Description |
---|---|
static ContextResolvedTable |
ContextResolvedTable.anonymous(ResolvedCatalogBaseTable<?> resolvedTable) |
static ContextResolvedTable |
ContextResolvedTable.anonymous(String hint,
ResolvedCatalogBaseTable<?> resolvedTable) |
ContextResolvedTable |
ContextResolvedTable.copy(Map<String,String> newOptions)
Copy the
ContextResolvedTable , replacing the underlying CatalogTable options. |
ContextResolvedTable |
CatalogManager.getTableOrError(ObjectIdentifier objectIdentifier)
Like
CatalogManager.getTable(ObjectIdentifier) , but throws an error when the table is not available
in any of the catalogs. |
static ContextResolvedTable |
ContextResolvedTable.permanent(ObjectIdentifier identifier,
Catalog catalog,
ResolvedCatalogBaseTable<?> resolvedTable) |
static ContextResolvedTable |
ContextResolvedTable.temporary(ObjectIdentifier identifier,
ResolvedCatalogBaseTable<?> resolvedTable) |
Modifier and Type | Method and Description |
---|---|
Optional<ContextResolvedTable> |
CatalogManager.getTable(ObjectIdentifier objectIdentifier)
Retrieves a fully qualified table.
|
Modifier and Type | Method and Description |
---|---|
ContextResolvedTable |
ExternalQueryOperation.getContextResolvedTable() |
ContextResolvedTable |
ExternalModifyOperation.getContextResolvedTable() |
ContextResolvedTable |
SourceQueryOperation.getContextResolvedTable() |
ContextResolvedTable |
SinkModifyOperation.getContextResolvedTable() |
Constructor and Description |
---|
ExternalModifyOperation(ContextResolvedTable contextResolvedTable,
QueryOperation child,
ChangelogMode changelogMode,
DataType physicalDataType) |
ExternalQueryOperation(ContextResolvedTable contextResolvedTable,
DataStream<E> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode) |
SinkModifyOperation(ContextResolvedTable contextResolvedTable,
QueryOperation child) |
SinkModifyOperation(ContextResolvedTable contextResolvedTable,
QueryOperation child,
Map<String,String> staticPartitions,
boolean overwrite,
Map<String,String> dynamicOptions) |
SourceQueryOperation(ContextResolvedTable contextResolvedTable) |
SourceQueryOperation(ContextResolvedTable contextResolvedTable,
Map<String,String> dynamicOptions) |
Modifier and Type | Method and Description |
---|---|
ContextResolvedTable |
CatalogSchemaTable.getContextResolvedTable() |
Constructor and Description |
---|
CatalogSchemaTable(ContextResolvedTable contextResolvedTable,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic,
boolean isStreaming)
Create a CatalogSchemaTable instance.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSourceUtils.convertDataStreamToRel(boolean isBatchMode,
ReadableConfig config,
FlinkRelBuilder relBuilder,
ContextResolvedTable contextResolvedTable,
DataStream<?> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode)
Converts a given
DataStream to a RelNode . |
static org.apache.calcite.rel.RelNode |
DynamicSourceUtils.convertSourceToRel(boolean isBatchMode,
ReadableConfig config,
FlinkRelBuilder relBuilder,
ContextResolvedTable contextResolvedTable,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic,
List<org.apache.calcite.rel.hint.RelHint> hints,
DynamicTableSource tableSource)
Converts a given
DynamicTableSource to a RelNode . |
Modifier and Type | Method and Description |
---|---|
ContextResolvedTable |
DynamicTableSourceSpec.getContextResolvedTable() |
ContextResolvedTable |
DynamicTableSinkSpec.getContextResolvedTable() |
Constructor and Description |
---|
DynamicTableSinkSpec(ContextResolvedTable contextResolvedTable,
List<SinkAbilitySpec> sinkAbilities) |
DynamicTableSourceSpec(ContextResolvedTable contextResolvedTable,
List<SourceAbilitySpec> sourceAbilities) |
Modifier and Type | Method and Description |
---|---|
static CatalogSourceTable |
CatalogSourceTable.createAnonymous(FlinkRelBuilder relBuilder,
ContextResolvedTable contextResolvedTable,
boolean isBatchMode)
Create a
CatalogSourceTable from an anonymous ContextResolvedTable . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.