This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from face82e56a [fix](meta) fix bug that backend tag may change to default
after upgrading to 1.2 (#15085)
add c6d93f739c [feature-wip](file reader) Merge stream_load_pipe to the
new file reader (#15035)
No new revisions were added by this update.
Summary of changes:
be/src/io/CMakeLists.txt | 1 +
be/src/io/fs/stream_load_pipe_reader.cpp | 209 +++++++++++++++++++++
be/src/io/fs/stream_load_pipe_reader.h | 97 ++++++++++
be/src/runtime/CMakeLists.txt | 1 +
be/src/runtime/exec_env.h | 3 +
be/src/runtime/exec_env_init.cpp | 2 +
...onsumer_pipe.h => kafka_consumer_pipe_reader.h} | 24 +--
be/src/runtime/stream_load/load_stream_mgr.h | 1 -
.../stream_load/new_load_stream_mgr.cpp} | 19 +-
.../{load_stream_mgr.h => new_load_stream_mgr.h} | 19 +-
be/src/runtime/stream_load/stream_load_executor.h | 1 -
be/src/runtime/stream_load/stream_load_pipe.h | 6 +-
be/src/util/doris_metrics.h | 1 +
.../exec/format/file_reader/new_file_factory.cpp | 7 +-
.../vec/exec/format/file_reader/new_file_factory.h | 3 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 2 -
.../jdbc_catalog_p0/test_mysql_jdbc_catalog.groovy | 1 -
17 files changed, 352 insertions(+), 45 deletions(-)
create mode 100644 be/src/io/fs/stream_load_pipe_reader.cpp
create mode 100644 be/src/io/fs/stream_load_pipe_reader.h
copy be/src/runtime/routine_load/{kafka_consumer_pipe.h =>
kafka_consumer_pipe_reader.h} (72%)
copy be/src/{pipeline/exec/aggregation_source_operator.cpp =>
runtime/stream_load/new_load_stream_mgr.cpp} (62%)
copy be/src/runtime/stream_load/{load_stream_mgr.h => new_load_stream_mgr.h}
(80%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
