This is an automated email from the ASF dual-hosted git repository. jark pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1b262d5a85db9fe6df7ca0a9d910cf63a274ac16 Author: Jark Wu <[email protected]> AuthorDate: Fri Mar 10 22:54:03 2023 +0800 [FLINK-30129][table] Rename PushFilterPastChangelogNormalizeRule to PushCalcPastChangelogNormalizeRule This closes #22156 --- ...zeRule.java => PushCalcPastChangelogNormalizeRule.java} | 14 +++++++------- .../table/planner/plan/rules/FlinkStreamRuleSets.scala | 2 +- ...st.java => PushCalcPastChangelogNormalizeRuleTest.java} | 4 ++-- ...Test.xml => PushCalcPastChangelogNormalizeRuleTest.xml} | 0 4 files changed, 10 insertions(+), 10 deletions(-) diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushFilterPastChangelogNormalizeRule.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRule.java similarity index 96% rename from flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushFilterPastChangelogNormalizeRule.java rename to flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRule.java index d9178061f9f..871deb72856 100644 --- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushFilterPastChangelogNormalizeRule.java +++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRule.java @@ -71,13 +71,13 @@ import static org.apache.flink.table.planner.plan.utils.RexNodeExtractor.extract */ @Internal @Value.Enclosing -public class PushFilterPastChangelogNormalizeRule - extends RelRule<PushFilterPastChangelogNormalizeRule.Config> { +public class PushCalcPastChangelogNormalizeRule + extends RelRule<PushCalcPastChangelogNormalizeRule.Config> { public static final RelOptRule INSTANCE = - new PushFilterPastChangelogNormalizeRule(Config.DEFAULT); + new PushCalcPastChangelogNormalizeRule(Config.DEFAULT); - public PushFilterPastChangelogNormalizeRule(Config config) { + public PushCalcPastChangelogNormalizeRule(Config config) { super(config); } @@ -299,15 +299,15 @@ public class PushFilterPastChangelogNormalizeRule // --------------------------------------------------------------------------------------------- - /** Configuration for {@link PushFilterPastChangelogNormalizeRule}. */ + /** Configuration for {@link PushCalcPastChangelogNormalizeRule}. */ @Value.Immutable(singleton = false) public interface Config extends RelRule.Config { Config DEFAULT = - ImmutablePushFilterPastChangelogNormalizeRule.Config.builder().build().onMatch(); + ImmutablePushCalcPastChangelogNormalizeRule.Config.builder().build().onMatch(); @Override default RelOptRule toRule() { - return new PushFilterPastChangelogNormalizeRule(this); + return new PushCalcPastChangelogNormalizeRule(this); } default Config onMatch() { diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala index 1df2b7bd131..b8512cf07fd 100644 --- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala +++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala @@ -470,7 +470,7 @@ object FlinkStreamRuleSets { // optimize window agg rule TwoStageOptimizedWindowAggregateRule.INSTANCE, // optimize ChangelogNormalize - PushFilterPastChangelogNormalizeRule.INSTANCE + PushCalcPastChangelogNormalizeRule.INSTANCE ) } diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushFilterPastChangelogNormalizeRuleTest.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRuleTest.java similarity index 98% rename from flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushFilterPastChangelogNormalizeRuleTest.java rename to flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRuleTest.java index a7e9f1d9893..4e0b2009e7d 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushFilterPastChangelogNormalizeRuleTest.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRuleTest.java @@ -33,8 +33,8 @@ import static org.apache.flink.table.api.DataTypes.BIGINT; import static org.apache.flink.table.api.DataTypes.INT; import static org.apache.flink.table.api.DataTypes.STRING; -/** Tests for {@link PushFilterPastChangelogNormalizeRule}. */ -public class PushFilterPastChangelogNormalizeRuleTest extends TableTestBase { +/** Tests for {@link PushCalcPastChangelogNormalizeRule}. */ +public class PushCalcPastChangelogNormalizeRuleTest extends TableTestBase { private StreamTableTestUtil util; diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/physical/stream/PushFilterPastChangelogNormalizeRuleTest.xml b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRuleTest.xml similarity index 100% rename from flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/physical/stream/PushFilterPastChangelogNormalizeRuleTest.xml rename to flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRuleTest.xml
