This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 697745bb58 [chore](workflow) Increase the build space for building
third-party libraries (#22322)
add 5da5fac37a [refactor](Nereids) add result sink node (#22254)
No new revisions were added by this update.
Summary of changes:
.../nereids/analyzer/UnboundOlapTableSink.java | 3 +-
.../UnboundResultSink.java} | 48 +++---
.../glue/translator/PhysicalPlanTranslator.java | 7 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 8 +-
.../nereids/properties/RequestPropertyDeriver.java | 7 +
.../org/apache/doris/nereids/rules/RuleSet.java | 2 +
.../org/apache/doris/nereids/rules/RuleType.java | 2 +
.../nereids/rules/analysis/BindExpression.java | 9 ++
.../doris/nereids/rules/analysis/BindRelation.java | 5 +
... => LogicalResultSinkToPhysicalResultSink.java} | 20 ++-
.../nereids/rules/rewrite/AddDefaultLimit.java | 3 +-
.../nereids/rules/rewrite/PullUpCteAnchor.java | 8 -
.../apache/doris/nereids/trees/plans/PlanType.java | 132 ++++++++--------
.../trees/plans/logical/LogicalCTEConsumer.java | 6 +-
...icalCTEProducer.java => LogicalResultSink.java} | 58 +++----
.../trees/plans/physical/PhysicalCTEConsumer.java | 2 +-
.../trees/plans/physical/PhysicalCTEProducer.java | 3 +-
.../trees/plans/physical/PhysicalDistribute.java | 4 +-
.../plans/physical/PhysicalHashAggregate.java | 4 +-
.../trees/plans/physical/PhysicalResultSink.java | 125 +++++++++++++++
.../nereids/trees/plans/visitor/SinkVisitor.java | 15 ++
.../org/apache/doris/nereids/JoinHintTest.java | 31 ++--
.../doris/nereids/parser/LimitClauseTest.java | 12 +-
.../doris/nereids/parser/NereidsParserTest.java | 42 ++---
.../nereids/postprocess/TopNRuntimeFilterTest.java | 4 +-
.../nereids/rules/analysis/AnalyzeCTETest.java | 10 +-
.../rules/analysis/AnalyzeSubQueryTest.java | 6 +-
.../rules/analysis/AnalyzeWhereSubqueryTest.java | 58 +++----
.../nereids/rules/analysis/BindRelationTest.java | 2 +-
.../analysis/CheckExpressionLegalityTest.java | 4 +-
.../rules/analysis/FillUpMissingSlotsTest.java | 44 +++---
.../rules/analysis/FunctionRegistryTest.java | 6 +-
.../nereids/rules/rewrite/ColumnPruningTest.java | 24 +--
.../nereids/rules/rewrite/InferPredicatesTest.java | 44 +++---
.../PushdownExpressionsInHashConditionTest.java | 6 +-
.../rules/rewrite/mv/SelectRollupIndexTest.java | 2 +
.../apache/doris/nereids/sqltest/InferTest.java | 6 +-
.../org/apache/doris/nereids/sqltest/JoinTest.java | 21 ++-
.../doris/nereids/trees/expressions/ViewTest.java | 4 +-
.../nereids_tpcds_shape_sf100_p0/shape/query1.out | 49 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query10.out | 89 +++++------
.../nereids_tpcds_shape_sf100_p0/shape/query11.out | 35 +++--
.../nereids_tpcds_shape_sf100_p0/shape/query12.out | 47 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query13.out | 61 ++++----
.../nereids_tpcds_shape_sf100_p0/shape/query14.out | 163 +++++++++----------
.../nereids_tpcds_shape_sf100_p0/shape/query15.out | 45 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query16.out | 61 ++++----
.../nereids_tpcds_shape_sf100_p0/shape/query17.out | 87 ++++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query18.out | 89 +++++------
.../nereids_tpcds_shape_sf100_p0/shape/query19.out | 63 ++++----
.../nereids_tpcds_shape_sf100_p0/shape/query2.out | 51 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query20.out | 43 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query21.out | 37 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query22.out | 37 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query23.out | 81 +++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query24.out | 41 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query25.out | 85 +++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query26.out | 57 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query27.out | 59 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query28.out | 97 ++++++------
.../nereids_tpcds_shape_sf100_p0/shape/query29.out | 77 ++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query3.out | 37 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query30.out | 47 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query31.out | 57 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query32.out | 41 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query33.out | 157 +++++++++----------
.../nereids_tpcds_shape_sf100_p0/shape/query34.out | 53 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query35.out | 93 +++++------
.../nereids_tpcds_shape_sf100_p0/shape/query36.out | 59 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query37.out | 45 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query38.out | 115 +++++++-------
.../nereids_tpcds_shape_sf100_p0/shape/query39.out | 27 ++--
.../nereids_tpcds_shape_sf100_p0/shape/query4.out | 67 ++++----
.../nereids_tpcds_shape_sf100_p0/shape/query40.out | 51 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query41.out | 39 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query42.out | 35 +++--
.../nereids_tpcds_shape_sf100_p0/shape/query43.out | 35 +++--
.../nereids_tpcds_shape_sf100_p0/shape/query44.out | 77 ++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query45.out | 75 ++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query46.out | 69 ++++----
.../nereids_tpcds_shape_sf100_p0/shape/query47.out | 37 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query48.out | 51 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query49.out | 155 +++++++++---------
.../nereids_tpcds_shape_sf100_p0/shape/query5.out | 129 +++++++--------
.../nereids_tpcds_shape_sf100_p0/shape/query50.out | 51 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query51.out | 75 ++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query52.out | 37 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query53.out | 57 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query54.out | 149 +++++++++---------
.../nereids_tpcds_shape_sf100_p0/shape/query55.out | 37 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query56.out | 161 +++++++++----------
.../nereids_tpcds_shape_sf100_p0/shape/query57.out | 37 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query58.out | 123 +++++++--------
.../nereids_tpcds_shape_sf100_p0/shape/query59.out | 59 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query6.out | 95 +++++------
.../nereids_tpcds_shape_sf100_p0/shape/query60.out | 157 +++++++++----------
.../nereids_tpcds_shape_sf100_p0/shape/query61.out | 107 ++++++-------
.../nereids_tpcds_shape_sf100_p0/shape/query62.out | 47 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query63.out | 57 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query65.out | 73 ++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query66.out | 105 ++++++-------
.../nereids_tpcds_shape_sf100_p0/shape/query67.out | 51 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query68.out | 73 ++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query69.out | 87 ++++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query7.out | 57 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query70.out | 85 +++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query71.out | 81 +++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query72.out | 103 ++++++------
.../nereids_tpcds_shape_sf100_p0/shape/query73.out | 53 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query74.out | 35 +++--
.../nereids_tpcds_shape_sf100_p0/shape/query75.out | 23 +--
.../nereids_tpcds_shape_sf100_p0/shape/query76.out | 81 +++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query77.out | 173 +++++++++++----------
.../nereids_tpcds_shape_sf100_p0/shape/query78.out | 113 +++++++-------
.../nereids_tpcds_shape_sf100_p0/shape/query79.out | 55 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query8.out | 73 ++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query80.out | 163 +++++++++----------
.../nereids_tpcds_shape_sf100_p0/shape/query81.out | 47 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query82.out | 45 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query83.out | 113 +++++++-------
.../nereids_tpcds_shape_sf100_p0/shape/query84.out | 55 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query85.out | 79 +++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query86.out | 47 +++---
.../nereids_tpcds_shape_sf100_p0/shape/query87.out | 113 +++++++-------
.../nereids_tpcds_shape_sf100_p0/shape/query88.out | 95 +++++------
.../nereids_tpcds_shape_sf100_p0/shape/query89.out | 59 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query9.out | 53 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query90.out | 53 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query91.out | 83 +++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query92.out | 41 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query93.out | 31 ++--
.../nereids_tpcds_shape_sf100_p0/shape/query94.out | 57 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query95.out | 73 ++++-----
.../nereids_tpcds_shape_sf100_p0/shape/query96.out | 43 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query97.out | 57 +++----
.../nereids_tpcds_shape_sf100_p0/shape/query98.out | 43 ++---
.../nereids_tpcds_shape_sf100_p0/shape/query99.out | 47 +++---
.../data/nereids_tpch_shape_sf1000_p0/shape/q1.out | 19 +--
.../nereids_tpch_shape_sf1000_p0/shape/q10.out | 49 +++---
.../nereids_tpch_shape_sf1000_p0/shape/q11.out | 65 ++++----
.../nereids_tpch_shape_sf1000_p0/shape/q12.out | 27 ++--
.../nereids_tpch_shape_sf1000_p0/shape/q13.out | 35 +++--
.../nereids_tpch_shape_sf1000_p0/shape/q14.out | 23 +--
.../nereids_tpch_shape_sf1000_p0/shape/q15.out | 53 +++----
.../nereids_tpch_shape_sf1000_p0/shape/q16.out | 37 ++---
.../nereids_tpch_shape_sf1000_p0/shape/q17.out | 33 ++--
.../nereids_tpch_shape_sf1000_p0/shape/q18.out | 43 ++---
.../nereids_tpch_shape_sf1000_p0/shape/q19.out | 23 +--
.../data/nereids_tpch_shape_sf1000_p0/shape/q2.out | 57 +++----
.../shape/q20-rewrite.out | 57 +++----
.../nereids_tpch_shape_sf1000_p0/shape/q20.out | 57 +++----
.../nereids_tpch_shape_sf1000_p0/shape/q21.out | 51 +++---
.../nereids_tpch_shape_sf1000_p0/shape/q22.out | 49 +++---
.../data/nereids_tpch_shape_sf1000_p0/shape/q3.out | 41 ++---
.../data/nereids_tpch_shape_sf1000_p0/shape/q4.out | 29 ++--
.../data/nereids_tpch_shape_sf1000_p0/shape/q5.out | 65 ++++----
.../data/nereids_tpch_shape_sf1000_p0/shape/q6.out | 13 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q7.out | 61 ++++----
.../data/nereids_tpch_shape_sf1000_p0/shape/q8.out | 87 ++++++-----
.../data/nereids_tpch_shape_sf1000_p0/shape/q9.out | 67 ++++----
.../data/nereids_tpch_shape_sf500_p0/shape/q1.out | 19 +--
.../data/nereids_tpch_shape_sf500_p0/shape/q10.out | 49 +++---
.../data/nereids_tpch_shape_sf500_p0/shape/q11.out | 65 ++++----
.../data/nereids_tpch_shape_sf500_p0/shape/q12.out | 27 ++--
.../data/nereids_tpch_shape_sf500_p0/shape/q13.out | 35 +++--
.../data/nereids_tpch_shape_sf500_p0/shape/q14.out | 23 +--
.../data/nereids_tpch_shape_sf500_p0/shape/q15.out | 53 +++----
.../data/nereids_tpch_shape_sf500_p0/shape/q16.out | 37 ++---
.../data/nereids_tpch_shape_sf500_p0/shape/q17.out | 33 ++--
.../data/nereids_tpch_shape_sf500_p0/shape/q18.out | 43 ++---
.../data/nereids_tpch_shape_sf500_p0/shape/q19.out | 23 +--
.../data/nereids_tpch_shape_sf500_p0/shape/q2.out | 57 +++----
.../data/nereids_tpch_shape_sf500_p0/shape/q20.out | 57 +++----
.../data/nereids_tpch_shape_sf500_p0/shape/q21.out | 51 +++---
.../data/nereids_tpch_shape_sf500_p0/shape/q22.out | 49 +++---
.../data/nereids_tpch_shape_sf500_p0/shape/q3.out | 41 ++---
.../data/nereids_tpch_shape_sf500_p0/shape/q4.out | 29 ++--
.../data/nereids_tpch_shape_sf500_p0/shape/q5.out | 65 ++++----
.../data/nereids_tpch_shape_sf500_p0/shape/q6.out | 13 +-
.../data/nereids_tpch_shape_sf500_p0/shape/q7.out | 61 ++++----
.../data/nereids_tpch_shape_sf500_p0/shape/q8.out | 87 ++++++-----
.../data/nereids_tpch_shape_sf500_p0/shape/q9.out | 63 ++++----
182 files changed, 5066 insertions(+), 4724 deletions(-)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/{trees/plans/logical/LogicalCTEAnchor.java
=> analyzer/UnboundResultSink.java} (55%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/{LogicalFileSinkToPhysicalFileSink.java
=> LogicalResultSinkToPhysicalResultSink.java} (66%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/{LogicalCTEProducer.java
=> LogicalResultSink.java} (56%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalResultSink.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
