Modifier and Type | Method and Description |
---|---|
static FlinkRelBuilder |
FlinkRelBuilder.of(org.apache.calcite.plan.Context context,
org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelOptSchema relOptSchema) |
static FlinkRelBuilder |
FlinkRelBuilder.of(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelOptSchema relOptSchema) |
Constructor and Description |
---|
RexFactory(org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
java.util.function.Supplier<org.apache.flink.table.planner.calcite.FlinkPlannerImpl> plannerSupplier,
java.util.function.Supplier<org.apache.calcite.sql.SqlDialect> sqlDialectSupplier,
java.util.function.Function<org.apache.flink.table.planner.calcite.FlinkPlannerImpl,FlinkRelBuilder> relBuilderSupplier) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.convertCollectToRel(FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
CollectModifyOperation collectModifyOperation,
ReadableConfig configuration,
ClassLoader classLoader)
Converts an
TableResult.collect() sink to a RelNode . |
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 |
DynamicSinkUtils.convertExternalToRel(FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
ExternalModifyOperation externalModifyOperation)
Converts an external sink (i.e.
|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.convertSinkToRel(FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
SinkModifyOperation sinkModifyOperation,
DynamicTableSink sink)
Converts a given
DynamicTableSink 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 |
---|---|
FlinkRelBuilder |
PlannerContext.createRelBuilder() |
Constructor and Description |
---|
QueryOperationConverter(FlinkRelBuilder relBuilder,
boolean isBatchMode) |
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.