This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 38530100d8 [fix](localgc) check gc only cache directory (#15238)
add b085ff49f0 [refactor](non-vec) delete non-vec data sink (#15283)
No new revisions were added by this update.
Summary of changes:
be/src/common/status.h | 3 +
be/src/exec/CMakeLists.txt | 2 +-
be/src/exec/base_scanner.h | 4 +-
be/src/exec/data_sink.cpp | 22 +-
be/src/exec/data_sink.h | 4 -
be/src/exec/exec_node.cpp | 50 +-
be/src/exec/exec_node.h | 1 -
be/src/exec/parquet_scanner.cpp | 140 +++
be/src/exec/parquet_scanner.h | 84 ++
be/src/exec/tablet_sink.cpp | 1497 -----------------------
be/src/exec/tablet_sink.h | 583 ---------
be/src/olap/push_handler.cpp | 8 +-
be/src/runtime/CMakeLists.txt | 14 -
be/src/runtime/buffered_block_mgr2.cc | 1216 ------------------
be/src/runtime/buffered_block_mgr2.h | 614 ----------
be/src/runtime/buffered_tuple_stream2.cc | 805 ------------
be/src/runtime/buffered_tuple_stream2.h | 412 -------
be/src/runtime/buffered_tuple_stream2.inline.h | 90 --
be/src/runtime/buffered_tuple_stream3.cc | 867 -------------
be/src/runtime/buffered_tuple_stream3.h | 647 ----------
be/src/runtime/buffered_tuple_stream3.inline.h | 55 -
be/src/runtime/export_sink.cpp | 276 -----
be/src/runtime/export_sink.h | 83 --
be/src/runtime/memory_scratch_sink.cpp | 97 --
be/src/runtime/memory_scratch_sink.h | 82 --
be/src/runtime/mysql_result_writer.cpp | 282 -----
be/src/runtime/mysql_result_writer.h | 79 --
be/src/runtime/mysql_table_sink.cpp | 86 --
be/src/runtime/mysql_table_sink.h | 73 --
be/src/runtime/mysql_table_writer.cpp | 182 ---
be/src/runtime/mysql_table_writer.h | 68 -
be/src/runtime/odbc_table_sink.cpp | 105 --
be/src/runtime/odbc_table_sink.h | 74 --
be/src/runtime/plan_fragment_executor.cpp | 134 +-
be/src/runtime/plan_fragment_executor.h | 10 -
be/src/runtime/result_writer.h | 6 -
be/src/runtime/row_batch.cpp | 48 -
be/src/runtime/row_batch.h | 17 +-
be/src/runtime/runtime_state.cpp | 9 -
be/src/runtime/runtime_state.h | 3 -
be/src/runtime/sorter.h | 53 -
be/src/vec/exec/join/vhash_join_node.cpp | 4 -
be/src/vec/exec/join/vhash_join_node.h | 1 -
be/src/vec/exec/join/vnested_loop_join_node.h | 4 -
be/src/vec/exec/scan/vscan_node.h | 4 -
be/src/vec/exec/vaggregation_node.cpp | 4 -
be/src/vec/exec/vaggregation_node.h | 1 -
be/src/vec/exec/vanalytic_eval_node.cpp | 4 -
be/src/vec/exec/vanalytic_eval_node.h | 1 -
be/src/vec/exec/varrow_scanner.h | 5 -
be/src/vec/exec/vassert_num_rows_node.h | 4 -
be/src/vec/exec/vbroker_scan_node.h | 5 -
be/src/vec/exec/vbroker_scanner.h | 5 -
be/src/vec/exec/vdata_gen_scan_node.cpp | 5 -
be/src/vec/exec/vdata_gen_scan_node.h | 4 -
be/src/vec/exec/vempty_set_node.h | 3 -
be/src/vec/exec/vexchange_node.cpp | 3 -
be/src/vec/exec/vexchange_node.h | 1 -
be/src/vec/exec/vjson_scanner.h | 4 -
be/src/vec/exec/vmysql_scan_node.h | 3 -
be/src/vec/exec/vschema_scan_node.h | 3 -
be/src/vec/exec/vselect_node.cpp | 4 -
be/src/vec/exec/vselect_node.h | 1 -
be/src/vec/exec/vset_operation_node.h | 3 -
be/src/vec/exec/vsort_node.cpp | 5 -
be/src/vec/exec/vsort_node.h | 24 +-
be/src/vec/exec/vunion_node.h | 3 -
be/src/vec/runtime/vfile_result_writer.h | 3 -
be/src/vec/runtime/vsorted_run_merger.cpp | 1 -
be/src/vec/sink/vdata_stream_sender.cpp | 4 -
be/src/vec/sink/vdata_stream_sender.h | 1 -
be/src/vec/sink/vmysql_result_writer.cpp | 4 -
be/src/vec/sink/vmysql_result_writer.h | 2 -
be/src/vec/sink/vmysql_table_writer.cpp | 8 +
be/src/vec/sink/vmysql_table_writer.h | 12 +-
be/src/vec/sink/vresult_file_sink.cpp | 4 -
be/src/vec/sink/vresult_file_sink.h | 1 -
be/src/vec/sink/vresult_sink.cpp | 4 -
be/src/vec/sink/vresult_sink.h | 2 -
be/src/vec/sink/vtable_sink.cpp | 5 -
be/src/vec/sink/vtable_sink.h | 2 -
be/src/vec/sink/vtablet_sink.cpp | 783 ++++++++++--
be/src/vec/sink/vtablet_sink.h | 459 ++++++-
be/test/CMakeLists.txt | 3 -
be/test/runtime/buffered_block_mgr2_test.cpp | 1246 -------------------
be/test/runtime/buffered_tuple_stream2_test.cpp | 821 -------------
be/test/runtime/test_env.cc | 28 -
be/test/runtime/test_env.h | 12 +-
88 files changed, 1440 insertions(+), 10958 deletions(-)
create mode 100644 be/src/exec/parquet_scanner.cpp
create mode 100644 be/src/exec/parquet_scanner.h
delete mode 100644 be/src/exec/tablet_sink.cpp
delete mode 100644 be/src/exec/tablet_sink.h
delete mode 100644 be/src/runtime/buffered_block_mgr2.cc
delete mode 100644 be/src/runtime/buffered_block_mgr2.h
delete mode 100644 be/src/runtime/buffered_tuple_stream2.cc
delete mode 100644 be/src/runtime/buffered_tuple_stream2.h
delete mode 100644 be/src/runtime/buffered_tuple_stream2.inline.h
delete mode 100644 be/src/runtime/buffered_tuple_stream3.cc
delete mode 100644 be/src/runtime/buffered_tuple_stream3.h
delete mode 100644 be/src/runtime/buffered_tuple_stream3.inline.h
delete mode 100644 be/src/runtime/export_sink.cpp
delete mode 100644 be/src/runtime/export_sink.h
delete mode 100644 be/src/runtime/memory_scratch_sink.cpp
delete mode 100644 be/src/runtime/memory_scratch_sink.h
delete mode 100644 be/src/runtime/mysql_result_writer.cpp
delete mode 100644 be/src/runtime/mysql_result_writer.h
delete mode 100644 be/src/runtime/mysql_table_sink.cpp
delete mode 100644 be/src/runtime/mysql_table_sink.h
delete mode 100644 be/src/runtime/mysql_table_writer.cpp
delete mode 100644 be/src/runtime/mysql_table_writer.h
delete mode 100644 be/src/runtime/odbc_table_sink.cpp
delete mode 100644 be/src/runtime/odbc_table_sink.h
delete mode 100644 be/src/runtime/sorter.h
delete mode 100644 be/test/runtime/buffered_block_mgr2_test.cpp
delete mode 100644 be/test/runtime/buffered_tuple_stream2_test.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
