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 2ec1d282c5 [fix](sink) fix END_OF_FILE error for pipeline caused by
VDataStreamSender eof (#20007)
add 8149b757c4 [Feature](Nereids)support insert into select command
(#18869)
No new revisions were added by this update.
Summary of changes:
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 1 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 6 +
.../org/apache/doris/nereids/NereidsPlanner.java | 16 +-
.../org/apache/doris/nereids/StatementContext.java | 6 +
.../doris/nereids/analyzer/NereidsAnalyzer.java | 6 +
.../nereids/analyzer/UnboundOlapTableSink.java | 135 +++
.../doris/nereids/glue/LogicalPlanAdapter.java | 9 +
.../glue/translator/PhysicalPlanTranslator.java | 97 ++-
.../doris/nereids/parser/LogicalPlanBuilder.java | 19 +-
.../properties/ChildOutputPropertyDeriver.java | 7 +
.../nereids/properties/RequestPropertyDeriver.java | 7 +
.../org/apache/doris/nereids/rules/RuleSet.java | 2 +
.../org/apache/doris/nereids/rules/RuleType.java | 3 +
.../rules/analysis/BindInsertTargetTable.java | 97 +++
.../doris/nereids/rules/analysis/BindRelation.java | 71 +-
.../analysis/CheckTypeToInsertTargetColumn.java | 57 ++
...ogicalOlapTableSinkToPhysicalOlapTableSink.java | 47 ++
.../doris/nereids/stats/StatsCalculator.java | 12 +
.../apache/doris/nereids/trees/plans/PlanType.java | 6 +-
.../plans/commands/InsertIntoTableCommand.java | 141 ++++
.../trees/plans/logical/LogicalOlapTableSink.java | 174 ++++
.../nereids/trees/plans/logical/RelationUtil.java | 52 --
.../plans/physical/PhysicalOlapTableSink.java | 208 +++++
.../nereids/trees/plans/visitor/PlanVisitor.java | 21 +
.../org/apache/doris/nereids/txn/Transaction.java | 234 ++++++
.../apache/doris/nereids/util/RelationUtil.java | 130 +++
.../java/org/apache/doris/qe/StmtExecutor.java | 12 +-
.../apache/doris/nereids/UnsupportedTypeTest.java | 5 +-
.../translator/PhysicalPlanTranslatorTest.java | 2 +-
.../doris/nereids/jobs/RewriteTopDownJobTest.java | 2 +-
.../nereids/jobs/cascades/DeriveStatsJobTest.java | 2 +-
.../org/apache/doris/nereids/memo/MemoTest.java | 2 +-
.../pattern/GroupExpressionMatchingTest.java | 2 +-
.../nereids/rules/analysis/BindRelationTest.java | 2 +-
.../rules/analysis/BindSlotReferenceTest.java | 2 +-
.../nereids/rules/analysis/CheckRowPolicyTest.java | 2 +-
.../LogicalWindowToPhysicalWindowTest.java | 2 +-
.../rewrite/logical/AggregateStrategiesTest.java | 2 +-
.../CheckAndStandardizeWindowFunctionTest.java | 2 +-
.../ExtractAndNormalizeWindowExpressionTest.java | 2 +-
.../rules/rewrite/logical/MergeProjectsTest.java | 2 +-
.../rewrite/logical/NormalizeAggregateTest.java | 2 +-
.../PushdownExpressionsInHashConditionTest.java | 10 +-
.../PushdownFilterThroughAggregationTest.java | 2 +-
.../rules/rewrite/logical/PushdownLimitTest.java | 2 +-
.../doris/nereids/stats/StatsCalculatorTest.java | 2 +-
.../trees/plans/ExplainInsertCommandTest.java | 108 +++
.../doris/nereids/trees/plans/PlanEqualsTest.java | 2 +-
.../doris/nereids/trees/plans/PlanOutputTest.java | 2 +-
.../apache/doris/nereids/util/MemoTestUtils.java | 2 +-
.../org/apache/doris/nereids/util/PlanChecker.java | 1 +
.../nereids_p0/insert_into_table/aggregate.out | 218 +++++
.../nereids_p0/insert_into_table/duplicate.out | 696 ++++++++++++++++
.../nereids_p0/insert_into_table/no_partition.out | 927 +++++++++++++++++++++
.../data/nereids_p0/insert_into_table/src.dat | 25 +
.../insert_into_table/type_cast_aggregate.out | 187 +++++
.../insert_into_table/type_cast_duplicate.out | 535 ++++++++++++
.../insert_into_table/type_cast_unique.out | 373 +++++++++
.../data/nereids_p0/insert_into_table/unique.out | 435 ++++++++++
.../suites/nereids_p0/aggregate/aggregate.groovy | 76 +-
.../nereids_p0/insert_into_table/aggregate.groovy | 88 ++
.../nereids_p0/insert_into_table/ddl/agg_nop_t.sql | 116 +++
.../nereids_p0/insert_into_table/ddl/agg_t.sql | 140 ++++
.../insert_into_table/ddl/agg_type_cast.sql | 92 ++
.../nereids_p0/insert_into_table/ddl/arr_t.sql | 10 +
.../nereids_p0/insert_into_table/ddl/dup_nop_t.sql | 116 +++
.../nereids_p0/insert_into_table/ddl/dup_t.sql | 140 ++++
.../insert_into_table/ddl/dup_type_cast.sql | 92 ++
.../nereids_p0/insert_into_table/ddl/uni_nop_t.sql | 234 ++++++
.../nereids_p0/insert_into_table/ddl/uni_t.sql | 282 +++++++
.../insert_into_table/ddl/uni_type_cast.sql | 190 +++++
.../nereids_p0/insert_into_table/duplicate.groovy | 88 ++
.../nereids_p0/insert_into_table/load.groovy | 79 ++
.../insert_into_table/no_partition.groovy | 214 +++++
.../insert_into_table/type_cast_aggregate.groovy | 76 ++
.../insert_into_table/type_cast_duplicate.groovy | 76 ++
.../insert_into_table/type_cast_unique.groovy | 128 +++
.../nereids_p0/insert_into_table/unique.groovy | 150 ++++
.../insert_into_table/unsupport_type.groovy | 33 +
79 files changed, 7329 insertions(+), 227 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/analyzer/UnboundOlapTableSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindInsertTargetTable.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/CheckTypeToInsertTargetColumn.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalOlapTableSinkToPhysicalOlapTableSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/InsertIntoTableCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalOlapTableSink.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/RelationUtil.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalOlapTableSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/txn/Transaction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/util/RelationUtil.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/ExplainInsertCommandTest.java
create mode 100644
regression-test/data/nereids_p0/insert_into_table/aggregate.out
create mode 100644
regression-test/data/nereids_p0/insert_into_table/duplicate.out
create mode 100644
regression-test/data/nereids_p0/insert_into_table/no_partition.out
create mode 100644 regression-test/data/nereids_p0/insert_into_table/src.dat
create mode 100644
regression-test/data/nereids_p0/insert_into_table/type_cast_aggregate.out
create mode 100644
regression-test/data/nereids_p0/insert_into_table/type_cast_duplicate.out
create mode 100644
regression-test/data/nereids_p0/insert_into_table/type_cast_unique.out
create mode 100644 regression-test/data/nereids_p0/insert_into_table/unique.out
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/agg_nop_t.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/agg_t.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/agg_type_cast.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/arr_t.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/dup_nop_t.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/dup_t.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/dup_type_cast.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/uni_nop_t.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/uni_t.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/ddl/uni_type_cast.sql
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/load.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/unique.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
