This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 401910c017f [feature](Cloud) Enable write into file cache for hdfs
writer (#33796)
add ceec5aaa35a [pipelineX](conf) Change pipeline tasks to pipelineX mode
(#33791)
No new revisions were added by this update.
Summary of changes:
be/src/exec/exec_node.cpp | 6 +-
be/src/io/file_factory.cpp | 2 +-
be/src/io/fs/multi_table_pipe.cpp | 1 +
be/src/pipeline/exec/aggregation_sink_operator.cpp | 2 +-
.../exec/group_commit_block_sink_operator.cpp} | 322 ++++++++++-----------
.../exec/group_commit_block_sink_operator.h | 82 +++++-
be/src/pipeline/exec/result_file_sink_operator.cpp | 4 +-
.../exec/streaming_aggregation_operator.cpp | 2 +-
be/src/pipeline/pipeline_fragment_context.cpp | 2 -
be/src/pipeline/pipeline_x/operator.cpp | 2 +
.../pipeline_x/pipeline_x_fragment_context.cpp | 11 +-
be/src/runtime/fragment_mgr.cpp | 223 ++++----------
be/src/runtime/group_commit_mgr.cpp | 1 +
be/src/runtime/query_context.cpp | 2 +-
be/src/runtime/query_context.h | 11 +-
be/src/runtime/runtime_filter_mgr.cpp | 4 +-
be/src/runtime/runtime_state.h | 10 +-
be/src/vec/exec/scan/new_olap_scan_node.cpp | 144 ++-------
be/src/vec/exec/scan/vscan_node.cpp | 69 +----
be/src/vec/exec/scan/vscan_node.h | 18 +-
be/src/vec/exec/vaggregation_node.cpp | 4 -
be/src/vec/exec/vaggregation_node.h | 5 -
be/src/vec/exec/vexchange_node.cpp | 15 +-
be/src/vec/runtime/vdata_stream_recvr.cpp | 2 +-
be/src/vec/sink/async_writer_sink.h | 23 +-
be/src/vec/sink/vdata_stream_sender.cpp | 145 +++-------
be/src/vec/sink/vdata_stream_sender.h | 1 -
be/src/vec/sink/vresult_file_sink.cpp | 9 +-
be/src/vec/sink/vresult_sink.cpp | 3 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 2 +
.../apache/doris/planner/StreamLoadPlanner.java | 2 +
.../main/java/org/apache/doris/qe/Coordinator.java | 3 +
.../java/org/apache/doris/qe/SessionVariable.java | 7 +-
.../load_p0/stream_load/test_pipeline_load.groovy | 2 +-
.../load_p0/stream_load/test_stream_load.groovy | 2 +-
35 files changed, 413 insertions(+), 730 deletions(-)
copy be/src/{vec/sink/group_commit_block_sink.cpp =>
pipeline/exec/group_commit_block_sink_operator.cpp} (72%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
