This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 4d3113c6e5 Update test_segcompaction_dup_keys_index.groovy (#23046)
add 3d4ec1ac88 [pipeline](exec) support async writer in jdbc sink in
pipeline query engine (#23144)
No new revisions were added by this update.
Summary of changes:
be/src/exec/odbc_connector.cpp | 74 +++++++++++++++++-----
be/src/exec/odbc_connector.h | 10 ++-
be/src/exec/table_connector.cpp | 63 +++---------------
be/src/exec/table_connector.h | 17 +++--
be/src/pipeline/pipeline_task.cpp | 3 +-
be/src/pipeline/task_scheduler.cpp | 24 ++-----
be/src/vec/exec/vjdbc_connector.cpp | 42 +++++++-----
be/src/vec/exec/vjdbc_connector.h | 12 +++-
be/src/vec/sink/vjdbc_table_sink.cpp | 50 ++++++---------
be/src/vec/sink/vjdbc_table_sink.h | 14 +++-
be/src/vec/sink/vmysql_table_sink.cpp | 11 ++--
be/src/vec/sink/vmysql_table_sink.h | 6 +-
be/src/vec/sink/vodbc_table_sink.cpp | 14 ++--
be/src/vec/sink/vtable_sink.cpp | 6 --
be/src/vec/sink/vtable_sink.h | 6 --
.../vec/sink/{ => writer}/async_result_writer.cpp | 53 ++++++++++------
be/src/vec/sink/{ => writer}/async_result_writer.h | 23 +++++--
.../writer/vjdbc_table_writer.cpp} | 50 ++++++++-------
.../sink/writer/vjdbc_table_writer.h} | 32 +++++-----
.../vec/sink/{ => writer}/vmysql_table_writer.cpp | 15 ++---
be/src/vec/sink/{ => writer}/vmysql_table_writer.h | 6 +-
21 files changed, 274 insertions(+), 257 deletions(-)
rename be/src/vec/sink/{ => writer}/async_result_writer.cpp (62%)
rename be/src/vec/sink/{ => writer}/async_result_writer.h (82%)
copy be/src/vec/{exprs/vstruct_literal.cpp =>
sink/writer/vjdbc_table_writer.cpp} (51%)
copy be/src/{exec/schema_scanner/schema_schemata_scanner.h =>
vec/sink/writer/vjdbc_table_writer.h} (62%)
rename be/src/vec/sink/{ => writer}/vmysql_table_writer.cpp (96%)
rename be/src/vec/sink/{ => writer}/vmysql_table_writer.h (92%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
