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/incubator-doris.git.
from 3a7b8e9 [Spark Load] Doris Support Using Hive Table to Build Global
Dict (#3063)
add f189a2e [Spark load][Be 1/1] Be handle push task (#3742)
No new revisions were added by this update.
Summary of changes:
be/src/agent/agent_server.cpp | 3 +-
be/src/agent/task_worker_pool.cpp | 21 +-
be/src/olap/olap_common.h | 7 +-
be/src/olap/push_handler.cpp | 283 +++++++++++++-
be/src/olap/push_handler.h | 45 +++
be/src/olap/task/engine_batch_load_task.cpp | 19 +-
be/test/olap/CMakeLists.txt | 1 +
.../push_handler_test.cpp} | 413 ++++++++++-----------
be/test/olap/test_data/push_broker_reader.parquet | Bin 0 -> 1133 bytes
run-ut.sh | 1 +
10 files changed, 543 insertions(+), 250 deletions(-)
copy be/test/{exec/parquet_scanner_test.cpp => olap/push_handler_test.cpp}
(57%)
create mode 100644 be/test/olap/test_data/push_broker_reader.parquet
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
