This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from fbbf4c420e [Bug](Agg-State) fix agg state function get wrong input
argument list (#20546)
add 09344eaab5 [feature](load) introduce single-stream-multi-table load
(#20006)
No new revisions were added by this update.
Summary of changes:
be/src/common/config.cpp | 4 +
be/src/common/config.h | 4 +
be/src/io/CMakeLists.txt | 1 +
be/src/io/file_factory.cpp | 15 +-
be/src/io/file_factory.h | 3 +-
be/src/io/fs/kafka_consumer_pipe.h | 6 +-
be/src/io/fs/multi_table_pipe.cpp | 288 +++++++++++++++++++++
be/src/io/fs/multi_table_pipe.h | 90 +++++++
be/src/io/fs/stream_load_pipe.h | 6 +-
be/src/runtime/fragment_mgr.cpp | 1 +
be/src/runtime/plan_fragment_executor.cpp | 2 -
.../routine_load/routine_load_task_executor.cpp | 35 ++-
be/src/runtime/stream_load/stream_load_context.h | 7 +
.../runtime/stream_load/stream_load_executor.cpp | 7 +
be/src/vec/exec/format/csv/csv_reader.cpp | 3 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 3 +-
be/test/CMakeLists.txt | 1 +
be/test/io/fs/multi_table_pipe_test.cpp | 72 ++++++
docs/en/docs/admin-manual/config/be-config.md | 6 +
docs/zh-CN/docs/admin-manual/config/be-config.md | 6 +
.../apache/doris/service/FrontendServiceImpl.java | 8 +
gensrc/thrift/BackendService.thrift | 7 +-
gensrc/thrift/FrontendService.thrift | 35 ++-
gensrc/thrift/PaloInternalService.thrift | 9 +-
gensrc/thrift/Types.thrift | 11 +-
25 files changed, 588 insertions(+), 42 deletions(-)
create mode 100644 be/src/io/fs/multi_table_pipe.cpp
create mode 100644 be/src/io/fs/multi_table_pipe.h
create mode 100644 be/test/io/fs/multi_table_pipe_test.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
