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 23e7423748 [pipeline](refactor) refactor pipeline task schedule logics
(#22028)
add f74f3e7944 [refactor](Nereids) add sink interface and abstract class
(#22150)
No new revisions were added by this update.
Summary of changes:
.../nereids/analyzer/UnboundOlapTableSink.java | 6 +-
.../nereids/processor/post/FragmentProcessor.java | 2 +-
.../processor/post/RuntimeFilterGenerator.java | 14 +-
.../processor/post/RuntimeFilterPruner.java | 2 +-
.../properties/ChildOutputPropertyDeriver.java | 21 +-
.../nereids/rules/rewrite/AddDefaultLimit.java | 16 +-
.../doris/nereids/rules/rewrite/ColumnPruning.java | 12 +-
.../nereids/rules/rewrite/PullUpCteAnchor.java | 14 +-
.../doris/nereids/stats/StatsCalculator.java | 20 +-
.../trees/copier/LogicalPlanDeepCopier.java | 17 +-
.../{commands/NoForward.java => algebra/Sink.java} | 6 +-
.../trees/plans/logical/LogicalFileSink.java | 4 +-
.../trees/plans/logical/LogicalOlapTableSink.java | 15 +-
.../{LogicalUnary.java => LogicalSink.java} | 20 +-
.../trees/plans/logical/LogicalSubQueryAlias.java | 2 +-
.../trees/plans/physical/PhysicalFileSink.java | 4 +-
.../plans/physical/PhysicalOlapTableSink.java | 10 +-
.../trees/plans/physical/PhysicalRelation.java | 2 +-
.../{PhysicalUnary.java => PhysicalSink.java} | 24 +-
.../trees/plans/visitor/CommandVisitor.java | 1 +
.../nereids/trees/plans/visitor/PlanVisitor.java | 303 +++++++--------------
.../trees/plans/visitor/RelationVisitor.java | 142 ++++++++++
.../nereids/trees/plans/visitor/SinkVisitor.java | 73 +++++
23 files changed, 401 insertions(+), 329 deletions(-)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/{commands/NoForward.java
=> algebra/Sink.java} (88%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/{LogicalUnary.java
=> LogicalSink.java} (65%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/{PhysicalUnary.java
=> PhysicalSink.java} (70%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/visitor/RelationVisitor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/visitor/SinkVisitor.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
