This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from b74e38c5c28 [chore](profile) add task state in profile (#42895)
add c69e8150830 [refactor](metrics) Refactor metrics for some operators
(#42909)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/analytic_sink_operator.cpp | 56 ++++++++++---------
be/src/pipeline/exec/analytic_sink_operator.h | 4 +-
be/src/pipeline/exec/analytic_source_operator.cpp | 36 +++++++------
be/src/pipeline/exec/analytic_source_operator.h | 8 ++-
be/src/pipeline/exec/cache_source_operator.cpp | 20 +++----
be/src/pipeline/exec/datagen_operator.cpp | 16 ++++--
be/src/pipeline/exec/datagen_operator.h | 2 +
be/src/pipeline/exec/exchange_sink_buffer.h | 1 -
be/src/pipeline/exec/exchange_sink_operator.cpp | 62 ++++++++--------------
be/src/pipeline/exec/exchange_sink_operator.h | 22 +-------
be/src/pipeline/exec/exchange_source_operator.cpp | 19 +++++--
be/src/pipeline/exec/exchange_source_operator.h | 3 ++
be/src/pipeline/exec/result_file_sink_operator.cpp | 6 ---
be/src/pipeline/exec/result_file_sink_operator.h | 14 -----
be/src/pipeline/exec/result_sink_operator.cpp | 3 +-
be/src/pipeline/exec/result_sink_operator.h | 2 -
be/src/vec/sink/vdata_stream_sender.cpp | 3 +-
be/src/vec/sink/vdata_stream_sender.h | 1 +
18 files changed, 128 insertions(+), 150 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
