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 ab69416922 [Bug](pipelineX) fix streaming agg (#24449)
add b9ddcbf729 [feature](merge-cloud) Rewrite code related to IOContext
(#24269)
No new revisions were added by this update.
Summary of changes:
be/src/exec/line_reader.h | 2 +-
be/src/io/cache/block/block_file_cache.h | 2 +-
.../io/cache/block/cached_remote_file_reader.cpp | 41 +++++++++++++++++-----
be/src/io/cache/block/cached_remote_file_reader.h | 4 +--
be/src/io/fs/broker_file_reader.cpp | 2 +-
be/src/io/fs/broker_file_reader.h | 2 +-
be/src/io/fs/buffered_reader.cpp | 2 +-
be/src/io/fs/buffered_reader.h | 2 +-
be/src/io/fs/file_reader.h | 2 +-
be/src/io/fs/file_writer.h | 4 +--
be/src/io/fs/hdfs_file_reader.h | 2 +-
be/src/io/fs/local_file_reader.cpp | 2 +-
be/src/io/fs/local_file_reader.h | 2 +-
be/src/io/fs/s3_file_reader.cpp | 2 +-
be/src/io/fs/s3_file_reader.h | 2 +-
be/src/io/fs/stream_load_pipe.cpp | 2 +-
be/src/io/fs/stream_load_pipe.h | 2 +-
be/src/io/io_common.h | 22 +++++-------
be/src/olap/delta_writer_context.h | 15 ++++----
be/src/olap/rowset/beta_rowset.cpp | 3 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 8 +++++
be/src/olap/rowset/beta_rowset_writer.cpp | 10 +++++-
be/src/olap/rowset/rowset_writer_context.h | 8 ++++-
be/src/olap/rowset/segment_v2/column_reader.cpp | 28 +++++++--------
be/src/olap/rowset/segment_v2/column_reader.h | 8 ++---
.../rowset/segment_v2/indexed_column_reader.cpp | 24 +++++++------
.../olap/rowset/segment_v2/ordinal_page_index.cpp | 19 +++++-----
be/src/olap/rowset/segment_v2/page_io.h | 32 ++++++++++-------
be/src/olap/rowset/segment_v2/page_pointer.h | 5 +++
be/src/olap/rowset/segment_v2/segment.cpp | 26 ++++++++------
be/src/olap/rowset/segment_v2/segment.h | 1 -
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 28 ++++++++-------
be/src/olap/rowset_builder.cpp | 1 +
be/src/olap/tablet.cpp | 11 +++---
be/src/runtime/load_stream.cpp | 16 +++++----
be/src/runtime/tablets_channel.cpp | 24 +++++++------
be/src/service/internal_service.cpp | 10 +++---
be/src/vec/exec/format/csv/csv_reader.cpp | 2 +-
be/src/vec/exec/format/csv/csv_reader.h | 2 +-
.../file_reader/new_plain_binary_line_reader.cpp | 2 +-
.../file_reader/new_plain_binary_line_reader.h | 2 +-
.../file_reader/new_plain_text_line_reader.h | 2 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 2 +-
be/src/vec/exec/format/json/new_json_reader.h | 2 +-
be/src/vec/exec/format/orc/vorc_reader.cpp | 2 +-
be/src/vec/exec/format/orc/vorc_reader.h | 2 +-
.../parquet/vparquet_column_chunk_reader.cpp | 2 +-
.../format/parquet/vparquet_column_chunk_reader.h | 2 +-
.../exec/format/parquet/vparquet_column_reader.cpp | 2 +-
.../exec/format/parquet/vparquet_column_reader.h | 2 +-
.../exec/format/parquet/vparquet_group_reader.cpp | 2 +-
.../exec/format/parquet/vparquet_group_reader.h | 2 +-
.../exec/format/parquet/vparquet_page_reader.cpp | 2 +-
.../vec/exec/format/parquet/vparquet_page_reader.h | 2 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 2 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 2 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 2 +-
be/src/vec/exec/format/table/iceberg_reader.h | 2 +-
.../format/table/transactional_hive_reader.cpp | 2 +-
.../exec/format/table/transactional_hive_reader.h | 2 +-
be/src/vec/sink/vtablet_sink_v2.cpp | 21 ++++++-----
be/src/vec/sink/vtablet_sink_v2.h | 1 +
be/test/olap/delta_writer_test.cpp | 8 ++---
gensrc/proto/internal_service.proto | 2 ++
gensrc/thrift/DataSinks.thrift | 2 ++
run-be-ut.sh | 4 ++-
66 files changed, 271 insertions(+), 189 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
