You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by go...@apache.org on 2023/01/17 13:17:45 UTC
[flink] branch master updated (128b0c4442a -> 14ea1a58e9b)

This is an automated email from the ASF dual-hosted git repository.

godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 128b0c4442a [FLINK-30675][sql-client] Decompose query result print from Executor
     add 14ea1a58e9b [FLINK-30376][table-planner] Introduce bushy join reorder rule based on greedy algorithm

No new revisions were added by this update.

Summary of changes:
 .../generated/optimizer_config_configuration.html  |    6 +
 .../table/api/config/OptimizerConfigOptions.java   |   12 +
 .../rules/logical/FlinkBushyJoinReorderRule.java   |  642 ++++++
 .../plan/rules/logical/FlinkJoinReorderRule.java   |  102 +
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |    2 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |    4 +-
 .../logical/RewriteMultiJoinConditionRule.scala    |   17 +-
 .../planner/utils/JavaScalaConversionUtil.scala    |    3 +
 .../DynamicPartitionPruningProgramTest.java        |  108 -
 .../runtime/batch/sql/join/JoinReorderITCase.java  |   64 +
 .../runtime/stream/sql/join/JoinReorderITCase.java |   74 +
 .../runtime/utils/JoinReorderITCaseBase.java       |  366 ++++
 .../plan/batch/sql/join/JoinReorderTest.xml        | 2134 +++++++++++++++----
 .../program/DynamicPartitionPruningProgramTest.xml |  133 +-
 .../logical/RewriteMultiJoinConditionRuleTest.xml  |   48 +
 .../plan/stream/sql/join/JoinReorderTest.xml       | 2200 ++++++++++++++++----
 .../plan/batch/sql/join/JoinReorderTest.scala      |    7 +-
 .../planner/plan/common/JoinReorderTestBase.scala  |  158 +-
 .../RewriteMultiJoinConditionRuleTest.scala        |   22 +
 .../plan/stream/sql/join/JoinReorderTest.scala     |    8 +-
 .../runtime/batch/sql/join/JoinITCase.scala        |  211 --
 21 files changed, 5047 insertions(+), 1274 deletions(-)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinReorderRule.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/join/JoinReorderITCase.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/JoinReorderITCase.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/utils/JoinReorderITCaseBase.java