You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by li...@apache.org on 2022/12/05 10:35:07 UTC
[doris] branch master updated (382d35c7e1 -> b30cd86e9e)
This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 382d35c7e1 [fix](runtime profile) Fix HighWaterMarkCounter update max Bug #14769
add b30cd86e9e [Refactor](pipeline) Refactor operator and builder code of pipeline (#14787)
No new revisions were added by this update.
Summary of changes:
be/src/exec/exec_node.cpp | 9 -
be/src/exec/exec_node.h | 16 +-
be/src/pipeline/CMakeLists.txt | 5 +-
be/src/pipeline/exec/aggregation_sink_operator.cpp | 53 +---
be/src/pipeline/exec/aggregation_sink_operator.h | 34 +--
.../pipeline/exec/aggregation_source_operator.cpp | 41 +--
be/src/pipeline/exec/aggregation_source_operator.h | 22 +-
be/src/pipeline/exec/empty_set_operator.cpp | 20 +-
be/src/pipeline/exec/empty_set_operator.h | 29 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 58 ++--
be/src/pipeline/exec/exchange_sink_operator.h | 40 +--
be/src/pipeline/exec/exchange_source_operator.cpp | 31 +--
be/src/pipeline/exec/exchange_source_operator.h | 29 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 33 ---
be/src/pipeline/exec/olap_scan_operator.h | 46 ----
be/src/pipeline/exec/operator.cpp | 39 +--
be/src/pipeline/exec/operator.h | 294 +++++++++++++++++----
be/src/pipeline/exec/repeat_operator.cpp | 56 +---
be/src/pipeline/exec/repeat_operator.h | 27 +-
be/src/pipeline/exec/result_sink_operator.cpp | 43 +--
be/src/pipeline/exec/result_sink_operator.h | 37 +--
be/src/pipeline/exec/scan_operator.cpp | 30 +--
be/src/pipeline/exec/scan_operator.h | 25 +-
be/src/pipeline/exec/sort_sink_operator.cpp | 27 +-
be/src/pipeline/exec/sort_sink_operator.h | 35 +--
be/src/pipeline/exec/sort_source_operator.cpp | 30 +--
be/src/pipeline/exec/sort_source_operator.h | 33 +--
.../exec/streaming_aggregation_sink_operator.cpp | 37 +--
.../exec/streaming_aggregation_sink_operator.h | 41 ++-
.../exec/streaming_aggregation_source_operator.cpp | 38 +--
.../exec/streaming_aggregation_source_operator.h | 26 +-
.../exec/table_function_operator.cpp} | 10 +-
be/src/pipeline/exec/table_function_operator.h | 68 +----
be/src/pipeline/pipeline.cpp | 1 -
be/src/pipeline/pipeline.h | 2 +-
be/src/pipeline/pipeline_fragment_context.cpp | 59 ++---
be/src/pipeline/task_scheduler.h | 1 -
be/src/vec/exec/scan/new_olap_scan_node.cpp | 1 -
be/src/vec/exec/scan/vscan_node.h | 2 +
be/src/vec/exec/vaggregation_node.h | 4 +-
be/src/vec/sink/vdata_stream_sender.h | 2 +
be/src/vec/sink/vresult_sink.h | 2 +
42 files changed, 469 insertions(+), 967 deletions(-)
delete mode 100644 be/src/pipeline/exec/olap_scan_operator.cpp
delete mode 100644 be/src/pipeline/exec/olap_scan_operator.h
copy be/src/{runtime/result_writer.cpp => pipeline/exec/table_function_operator.cpp} (83%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org