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 2022/08/04 02:46:49 UTC
[flink] branch master updated (8236644816a -> ae186e8650f)
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 8236644816a [FLINK-28492][table-planner] Support "ANALYZE TABLE" execution
add ae186e8650f [FLINK-28708][table-planner] Introduce planner rules to optimize DPP pattern
No new revisions were added by this update.
Summary of changes:
.../generated/optimizer_config_configuration.html | 6 +
.../table/api/config/OptimizerConfigOptions.java | 9 +
.../plan/abilities/source/FilterPushDownSpec.java | 4 +
.../batch/DynamicPartitionPruningRule.java | 926 +++++++++++++++++++++
.../FlinkRelMdPercentageOriginalRows.scala | 4 +-
...tchPhysicalDynamicFilteringDataCollector.scala} | 41 +-
...hPhysicalDynamicFilteringTableSourceScan.scala} | 52 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 25 +-
.../table/planner/plan/utils/FlinkRexUtil.scala | 2 +-
.../planner/factories/TestValuesTableFactory.java | 70 +-
.../batch/DynamicPartitionPruningRuleTest.java | 382 +++++++++
.../batch/DynamicPartitionPruningRuleTest.xml | 701 ++++++++++++++++
12 files changed, 2172 insertions(+), 50 deletions(-)
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/DynamicPartitionPruningRule.java
copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchPhysicalIntermediateTableScan.scala => BatchPhysicalDynamicFilteringDataCollector.scala} (59%)
copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchPhysicalTableSourceScan.scala => BatchPhysicalDynamicFilteringTableSourceScan.scala} (69%)
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/batch/DynamicPartitionPruningRuleTest.java
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/physical/batch/DynamicPartitionPruningRuleTest.xml