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 2ad46c5826 [fix](show) show load warning support load v2 (#22759)
add 5c2fae7ce5 [pipeline](exec) Refactor the table sink code in remove
unless code (#23223)
No new revisions were added by this update.
Summary of changes:
be/src/exec/data_sink.cpp | 5 +-
be/src/exec/data_sink.h | 11 ++-
be/src/exec/odbc_connector.cpp | 7 +-
be/src/exec/odbc_connector.h | 5 +-
be/src/exec/table_connector.h | 5 +-
be/src/pipeline/exec/table_sink_operator.h | 4 +-
be/src/vec/exec/vjdbc_connector.h | 7 +-
be/src/vec/sink/multi_cast_data_stream_sink.h | 6 +-
be/src/vec/sink/vdata_stream_sender.cpp | 8 +-
be/src/vec/sink/vdata_stream_sender.h | 3 -
be/src/vec/sink/vjdbc_table_sink.cpp | 99 ----------------------
be/src/vec/sink/vjdbc_table_sink.h | 64 --------------
be/src/vec/sink/vmemory_scratch_sink.cpp | 2 +-
be/src/vec/sink/vmemory_scratch_sink.h | 2 -
be/src/vec/sink/vmysql_table_sink.cpp | 71 ----------------
be/src/vec/sink/vmysql_table_sink.h | 59 -------------
be/src/vec/sink/vodbc_table_sink.cpp | 93 --------------------
be/src/vec/sink/vresult_file_sink.cpp | 8 +-
be/src/vec/sink/vresult_file_sink.h | 2 -
be/src/vec/sink/vresult_sink.cpp | 2 +-
be/src/vec/sink/vresult_sink.h | 5 --
be/src/vec/sink/vtable_sink.cpp | 69 ---------------
be/src/vec/sink/vtable_sink.h | 98 +++++++++++++++++++--
be/src/vec/sink/vtablet_sink.cpp | 4 +-
be/src/vec/sink/vtablet_sink.h | 3 -
be/src/vec/sink/writer/async_result_writer.cpp | 21 +++--
be/src/vec/sink/writer/async_result_writer.h | 18 ++--
be/src/vec/sink/writer/vjdbc_table_writer.cpp | 25 +++++-
be/src/vec/sink/writer/vjdbc_table_writer.h | 15 +++-
be/src/vec/sink/writer/vmysql_table_writer.cpp | 8 +-
be/src/vec/sink/writer/vmysql_table_writer.h | 7 +-
...dbc_table_writer.cpp => vodbc_table_writer.cpp} | 26 ++++--
.../vodbc_table_writer.h} | 40 ++++-----
33 files changed, 240 insertions(+), 562 deletions(-)
delete mode 100644 be/src/vec/sink/vjdbc_table_sink.cpp
delete mode 100644 be/src/vec/sink/vjdbc_table_sink.h
delete mode 100644 be/src/vec/sink/vmysql_table_sink.cpp
delete mode 100644 be/src/vec/sink/vmysql_table_sink.h
delete mode 100644 be/src/vec/sink/vodbc_table_sink.cpp
delete mode 100644 be/src/vec/sink/vtable_sink.cpp
copy be/src/vec/sink/writer/{vjdbc_table_writer.cpp => vodbc_table_writer.cpp}
(63%)
rename be/src/vec/sink/{vodbc_table_sink.h => writer/vodbc_table_writer.h}
(55%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
