This is an automated email from the ASF dual-hosted git repository.
englefly pushed a change to branch set-runtime-filter
in repository https://gitbox.apache.org/repos/asf/doris.git
from 0fe6a84210a support rf on set operator: be part
add e0412b520cd setop rf (fe part) (#49399)
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 +-
.../glue/translator/PhysicalPlanTranslator.java | 33 +
.../glue/translator/PlanTranslatorContext.java | 9 +
.../glue/translator/RunTimeFilterTranslatorV2.java | 118 ++++
.../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 | 183 ++++++
.../runtimefilterv2/RuntimeFilterContextV2.java | 75 +++
.../post/runtimefilterv2/RuntimeFilterV2.java | 131 ++++
.../runtimefilterv2/RuntimeFilterV2Generator.java | 72 +++
.../trees/plans/physical/AbstractPhysicalJoin.java | 6 +-
.../trees/plans/physical/AbstractPhysicalPlan.java | 16 +-
.../plans/physical/PhysicalCatalogRelation.java | 3 +
.../trees/plans/physical/PhysicalHashJoin.java | 3 +
.../trees/plans/physical/PhysicalIntersect.java | 4 +-
.../trees/plans/physical/PhysicalOlapScan.java | 13 +-
.../trees/plans/physical/PhysicalSetOperation.java | 10 +
.../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 | 71 +-
.../org/apache/doris/planner/SchemaScanNode.java | 2 +-
.../doris/planner/RuntimeFilterGeneratorTest.java | 711 ---------------------
.../data/query_p0/runtimefilterV2/rfv2.out | Bin 0 -> 1791 bytes
.../suites/query_p0/runtimefilterV2/rfv2.groovy | 63 ++
30 files changed, 926 insertions(+), 774 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
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/RuntimeFilterGeneratorTest.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]
