Deprecated API

Contents

• Deprecated Classes
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors

Deprecated Classes

Class and Description
org.apache.flink.table.planner.operations.InternalDataStreamQueryOperation

Deprecated Fields

Field and Description
org.apache.calcite.sql2rel.SqlToRelConverter.DEFAULT_IN_SUBQUERY_THRESHOLD

Deprecated Methods

Method and Description
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, boolean, RexNode, String, Iterable<? extends RexNode>)
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, boolean, RexNode, String, RexNode...)
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, RexNode, String, Iterable<? extends RexNode>)
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, RexNode, String, RexNode...)
org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.createSourceFunctionTransformation(StreamExecutionEnvironment, SourceFunction<RowData>, boolean, String, TypeInformation<RowData>, int, boolean) This method relies on the SourceFunction API, which is due to be removed.
org.apache.calcite.sql2rel.RelDecorrelator.decorrelateQuery(RelNode)
org.apache.calcite.sql2rel.SqlToRelConverter.enableDecorrelation()
org.apache.calcite.sql2rel.SqlToRelConverter.getInSubqueryThreshold()
org.apache.flink.table.planner.utils.TableConfigUtils.getMaxIdleStateRetentionTime(ReadableConfig)
org.apache.calcite.tools.RelBuilder.groupKey(ImmutableBitSet, boolean, ImmutableList<ImmutableBitSet>) Use RelBuilder.groupKey(ImmutableBitSet, Iterable).
org.apache.calcite.tools.RelBuilder.groupKey(Iterable<? extends RexNode>, boolean, Iterable<? extends Iterable<? extends RexNode>>) Now that indicator is deprecated, use RelBuilder.groupKey(Iterable, Iterable), which has the same behavior as calling this method with indicator = false.
org.apache.calcite.sql.validate.SqlValidatorImpl.isAggregate(SqlNode)
org.apache.calcite.sql2rel.SqlToRelConverter.isTrimUnusedFields()
org.apache.flink.table.planner.functions.casting.CodeGeneratorCastRule.Context.legacyBehaviour()
org.apache.flink.table.planner.functions.casting.CastRule.Context.legacyBehaviour()

Deprecated Constructors

Constructor and Description
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateExpandDistinctAggregatesRule(Class<? extends LogicalAggregate>, boolean, RelFactories.JoinFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateExpandDistinctAggregatesRule(Class<? extends LogicalAggregate>, RelFactories.JoinFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory, boolean)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory, RelFactories.ProjectFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory, RelFactories.ProjectFactory, boolean)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateRemoveRule(Class<? extends Aggregate>)
org.apache.flink.table.planner.plan.rules.logical.FlinkBushyJoinReorderRule(RelBuilderFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkBushyJoinReorderRule(RelFactories.JoinFactory, RelFactories.ProjectFactory, RelFactories.FilterFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinPushExpressionsRule(Class<? extends Join>, RelFactories.ProjectFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinReorderRule(RelBuilderFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinReorderRule(RelFactories.JoinFactory, RelFactories.ProjectFactory, RelFactories.FilterFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinToMultiJoinRule(Class<? extends Join>)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinToMultiJoinRule(Class<? extends Join>, RelBuilderFactory)
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelOptTable)
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelTraitSet, RelOptTable)
org.apache.calcite.sql2rel.SqlToRelConverter(RelOptTable.ViewExpander, SqlValidator, Prepare.CatalogReader, RelOptCluster, SqlRexConvertletTable)
org.apache.calcite.sql2rel.SqlToRelConverter(RelOptTable.ViewExpander, SqlValidator, Prepare.CatalogReader, RelOptPlanner, RexBuilder, SqlRexConvertletTable)