This is an automated email from the ASF dual-hosted git repository.
englefly pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 6c668d01a22 [Bug](distinct) fix distinct function with over return
error result (#51875)
add deb2523728b [feat](nereids) support runtime filter for
except/intersect (FE part) (#49947)
No new revisions were added by this update.
Summary of changes:
.../org/apache/doris/datasource/FileScanNode.java | 2 +-
.../org/apache/doris/nereids/CascadesContext.java | 13 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 5 +-
.../glue/translator/PhysicalPlanTranslator.java | 96 +++++++++++
.../glue/translator/PlanTranslatorContext.java | 10 ++
.../glue/translator/RunTimeFilterTranslatorV2.java | 120 +++++++++++++
.../nereids/processor/post/PlanPostProcessors.java | 4 +-
.../processor/post/RuntimeFilterContext.java | 10 +-
.../processor/post/RuntimeFilterGenerator.java | 15 +-
.../post/runtimefilterv2/PushDownContext.java | 97 +++++++++++
.../post/runtimefilterv2/PushDownVisitor.java | 188 +++++++++++++++++++++
.../runtimefilterv2/RuntimeFilterContextV2.java | 86 ++++++++++
.../post/runtimefilterv2/RuntimeFilterV2.java | 148 ++++++++++++++++
.../runtimefilterv2/RuntimeFilterV2Generator.java | 104 ++++++++++++
.../apache/doris/nereids/properties/DataTrait.java | 2 +-
.../trees/plans/logical/LogicalIntersect.java | 7 +-
.../trees/plans/physical/AbstractPhysicalJoin.java | 6 +-
.../trees/plans/physical/AbstractPhysicalPlan.java | 16 +-
.../plans/physical/PhysicalCatalogRelation.java | 7 +
.../trees/plans/physical/PhysicalFileScan.java | 6 +-
.../trees/plans/physical/PhysicalHashJoin.java | 3 +
.../trees/plans/physical/PhysicalIntersect.java | 11 +-
.../trees/plans/physical/PhysicalJdbcScan.java | 5 +
.../trees/plans/physical/PhysicalOlapScan.java | 13 +-
.../trees/plans/physical/PhysicalSetOperation.java | 14 ++
.../org/apache/doris/planner/DataStreamSink.java | 2 +-
.../org/apache/doris/planner/HashJoinNode.java | 9 +-
.../apache/doris/planner/NestedLoopJoinNode.java | 5 +-
.../org/apache/doris/planner/OlapScanNode.java | 8 -
.../java/org/apache/doris/planner/PlanNode.java | 12 +-
.../org/apache/doris/planner/RuntimeFilter.java | 73 ++++++--
.../org/apache/doris/planner/SchemaScanNode.java | 2 +-
.../java/org/apache/doris/qe/SessionVariable.java | 3 +
.../doris/planner/RuntimeFilterGeneratorTest.java | 80 ++++-----
.../data/empty_relation/eliminate_empty.out | Bin 3091 -> 3183 bytes
.../data/nereids_p0/set_operations/except.out | Bin 2726 -> 2962 bytes
.../data/query_p0/runtimefilterV2/rfv2.out | Bin 0 -> 1703 bytes
.../tpcds_sf100/noStatsRfPrune/query14.out | Bin 10025 -> 10111 bytes
.../tpcds_sf100/noStatsRfPrune/query38.out | Bin 3183 -> 3294 bytes
.../tpcds_sf100/noStatsRfPrune/query8.out | Bin 10013 -> 10066 bytes
.../tpcds_sf100/no_stats_shape/query14.out | Bin 10659 -> 10745 bytes
.../tpcds_sf100/no_stats_shape/query38.out | Bin 3343 -> 3454 bytes
.../tpcds_sf100/no_stats_shape/query8.out | Bin 10057 -> 10110 bytes
.../shape_check/tpcds_sf100/rf_prune/query14.out | Bin 10099 -> 10181 bytes
.../shape_check/tpcds_sf100/rf_prune/query38.out | Bin 3179 -> 3290 bytes
.../shape_check/tpcds_sf100/rf_prune/query8.out | Bin 10011 -> 10064 bytes
.../shape_check/tpcds_sf100/rf_prune/query87.out | Bin 2951 -> 3033 bytes
.../data/shape_check/tpcds_sf100/shape/query14.out | Bin 10573 -> 10655 bytes
.../data/shape_check/tpcds_sf100/shape/query38.out | Bin 3339 -> 3450 bytes
.../data/shape_check/tpcds_sf100/shape/query8.out | Bin 10055 -> 10108 bytes
.../data/shape_check/tpcds_sf100/shape/query87.out | Bin 3111 -> 3193 bytes
.../tpcds_sf1000/bs_downgrade_shape/query8.out | Bin 10055 -> 10108 bytes
.../data/shape_check/tpcds_sf1000/hint/query14.out | Bin 10728 -> 10810 bytes
.../data/shape_check/tpcds_sf1000/hint/query8.out | Bin 10258 -> 10311 bytes
.../shape_check/tpcds_sf1000/shape/query14.out | Bin 10569 -> 10651 bytes
.../data/shape_check/tpcds_sf1000/shape/query8.out | Bin 10055 -> 10108 bytes
.../shape_check/tpcds_sf10t_orc/shape/query8.out | Bin 10055 -> 10108 bytes
.../runtime_filter/test_pushdown_setop.out | Bin 1884 -> 1976 bytes
.../suites/empty_relation/eliminate_empty.groovy | 2 +
.../testAggQuqeryOnAggMV6.groovy | 4 +-
.../suites/nereids_p0/set_operations/except.groovy | 11 +-
.../suites/query_p0/runtimefilterV2/rfv2.groovy | 87 ++++++++++
62 files changed, 1165 insertions(+), 121 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/RunTimeFilterTranslatorV2.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/runtimefilterv2/PushDownContext.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/runtimefilterv2/PushDownVisitor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/runtimefilterv2/RuntimeFilterContextV2.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/runtimefilterv2/RuntimeFilterV2.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/runtimefilterv2/RuntimeFilterV2Generator.java
create mode 100644 regression-test/data/query_p0/runtimefilterV2/rfv2.out
create mode 100644 regression-test/suites/query_p0/runtimefilterV2/rfv2.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
