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 69a6a715301 [Opt](partial update) Add some cases for partial update
(#48161)
add e2a9897b831 [refactor](result sink) refactor result writers (#48368)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/result_file_sink_operator.cpp | 11 +-
be/src/pipeline/exec/result_file_sink_operator.h | 4 +-
be/src/pipeline/exec/result_sink_operator.cpp | 67 +--
be/src/pipeline/exec/result_sink_operator.h | 14 +-
be/src/runtime/buffer_control_block.cpp | 495 ---------------------
be/src/runtime/buffer_control_block.h | 184 --------
be/src/runtime/memory/mem_tracker_limiter.cpp | 4 +-
be/src/runtime/result_block_buffer.cpp | 245 ++++++++++
be/src/runtime/result_block_buffer.h | 125 ++++++
be/src/runtime/result_buffer_mgr.cpp | 133 +++---
be/src/runtime/result_buffer_mgr.h | 30 +-
.../arrow_flight/arrow_flight_batch_reader.cpp | 19 +-
be/src/service/internal_service.cpp | 45 +-
be/src/service/point_query_executor.cpp | 39 +-
be/src/vec/sink/varrow_flight_result_writer.cpp | 124 +++++-
be/src/vec/sink/varrow_flight_result_writer.h | 61 ++-
be/src/vec/sink/vmysql_result_writer.cpp | 75 +++-
be/src/vec/sink/vmysql_result_writer.h | 54 ++-
be/src/vec/sink/writer/vfile_result_writer.cpp | 9 +-
be/src/vec/sink/writer/vfile_result_writer.h | 9 +-
be/test/CMakeLists.txt | 1 -
be/test/runtime/result_buffer_mgr_test.cpp | 70 ++-
.../serde/data_type_serde_mysql_test.cpp | 18 +-
.../vec/sink/arrow_result_block_buffer_test.cpp | 377 ++++++++++++++++
be/test/vec/sink/get_result_batch_test.cpp | 148 ++++++
be/test/vec/sink/result_block_buffer_test.cpp | 319 +++++++++++++
26 files changed, 1726 insertions(+), 954 deletions(-)
delete mode 100644 be/src/runtime/buffer_control_block.cpp
delete mode 100644 be/src/runtime/buffer_control_block.h
create mode 100644 be/src/runtime/result_block_buffer.cpp
create mode 100644 be/src/runtime/result_block_buffer.h
create mode 100644 be/test/vec/sink/arrow_result_block_buffer_test.cpp
create mode 100644 be/test/vec/sink/get_result_batch_test.cpp
create mode 100644 be/test/vec/sink/result_block_buffer_test.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
