From de38468f1645952555b57c3f7564ed4d5f1c0033 Mon Sep 17 00:00:00 2001 From: Sergey Nuyanzin Date: Sun, 3 Mar 2024 16:51:29 +0100 Subject: [PATCH] update --- .../batch/RemoveRedundantLocalRankRule.java | 17 ++--------------- 1 file changed, 2 insertions(+), 15 deletions(-) diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/RemoveRedundantLocalRankRule.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/RemoveRedundantLocalRankRule.java index 73b20f1d42fe6..ebb22007f111a 100644 --- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/RemoveRedundantLocalRankRule.java +++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/RemoveRedundantLocalRankRule.java @@ -30,19 +30,12 @@ import java.util.Collections; /** - * Planner rule that matches a global [[BatchPhysicalRank]] on a local [[BatchPhysicalRank]], and - * merge them into a global [[BatchPhysicalRank]]. + * Planner rule that matches a global {@link BatchPhysicalRank} on a local {@link + * BatchPhysicalRank}, and merge them into a global {@link BatchPhysicalRank}. */ @Value.Enclosing public class RemoveRedundantLocalRankRule extends RelRule { - // /*( - // operand( - // classOf[BatchPhysicalRank], - // operand( - // classOf[BatchPhysicalRank], - // operand(classOf[RelNode], FlinkConventions.BATCH_PHYSICAL, any))), - // "RemoveRedundantLocalRankRule") {*/ public RemoveRedundantLocalRankRule(RemoveRedundantLocalRankRuleConfig config) { super(config); @@ -106,9 +99,3 @@ public static class RemoveRedundantLocalRankRuleHolder { RemoveRedundantLocalRankRuleConfig.DEFAULT.toRule(); } } - -/* -object RemoveRedundantLocalRankRule { - val INSTANCE: RelOptRule = new RemoveRedundantLocalRankRule -} -*/