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 fc12362a6d [feature-wip](arrow-flight)(step2) FE support Arrow Flight
server (#24314)
add dc9fa1a4f1 [Refactor](Sink) convert to tablet sink to tablet writer
(#24474)
No new revisions were added by this update.
Summary of changes:
be/src/exec/data_sink.cpp | 23 +-
be/src/exec/odbc_connector.cpp | 2 +-
be/src/exec/odbc_connector.h | 2 +-
be/src/exec/table_connector.h | 2 +-
be/src/pipeline/exec/olap_table_sink_operator.h | 2 +-
be/src/pipeline/exec/olap_table_sink_v2_operator.h | 2 +-
be/src/runtime/exec_env.h | 7 +-
be/src/runtime/exec_env_init.cpp | 2 +-
be/src/runtime/result_writer.h | 2 +-
be/src/vec/exec/vjdbc_connector.cpp | 2 +-
be/src/vec/exec/vjdbc_connector.h | 2 +-
be/src/vec/sink/async_writer_sink.h | 4 +-
be/src/vec/sink/autoinc_buffer.cpp | 6 +-
be/src/vec/sink/autoinc_buffer.h | 6 +-
be/src/vec/sink/delta_writer_v2_pool.cpp | 4 +-
be/src/vec/sink/delta_writer_v2_pool.h | 4 +-
be/src/vec/sink/group_commit_vtablet_sink.cpp | 40 -
be/src/vec/sink/group_commit_vtablet_sink.h | 34 -
be/src/vec/sink/varrow_flight_result_writer.cpp | 2 +-
be/src/vec/sink/varrow_flight_result_writer.h | 2 +-
be/src/vec/sink/vmysql_result_writer.cpp | 2 +-
be/src/vec/sink/vmysql_result_writer.h | 2 +-
be/src/vec/sink/vresult_file_sink.cpp | 1 -
be/src/vec/sink/vtablet_block_convertor.cpp | 13 +-
be/src/vec/sink/vtablet_block_convertor.h | 10 +-
be/src/vec/sink/vtablet_finder.cpp | 8 +-
be/src/vec/sink/vtablet_finder.h | 6 +-
be/src/vec/sink/vtablet_sink.cpp | 1820 +-------------------
be/src/vec/sink/vtablet_sink.h | 499 +-----
be/src/vec/sink/vtablet_sink_v2.cpp | 6 +-
be/src/vec/sink/vtablet_sink_v2.h | 4 +-
be/src/vec/sink/writer/async_result_writer.cpp | 17 +-
be/src/vec/sink/writer/async_result_writer.h | 5 +-
be/src/vec/sink/writer/vfile_result_writer.cpp | 6 +-
be/src/vec/sink/writer/vfile_result_writer.h | 7 +-
be/src/vec/sink/writer/vjdbc_table_writer.h | 2 +-
be/src/vec/sink/writer/vmysql_table_writer.cpp | 2 +-
be/src/vec/sink/writer/vmysql_table_writer.h | 2 +-
be/src/vec/sink/writer/vodbc_table_writer.h | 2 +-
.../vtablet_writer.cpp} | 925 +++++-----
.../{vtablet_sink.h => writer/vtablet_writer.h} | 164 +-
be/test/vec/exec/delta_writer_v2_pool_test.cpp | 7 +-
be/test/vec/exec/vtablet_sink_test.cpp | 14 +-
43 files changed, 630 insertions(+), 3044 deletions(-)
delete mode 100644 be/src/vec/sink/group_commit_vtablet_sink.cpp
delete mode 100644 be/src/vec/sink/group_commit_vtablet_sink.h
copy be/src/vec/sink/{vtablet_sink.cpp => writer/vtablet_writer.cpp} (86%)
copy be/src/vec/sink/{vtablet_sink.h => writer/vtablet_writer.h} (78%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
