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 531616b8ee [Fix](bucket)fix partition with no history data &&
AutoBucketUtilsTest (#16516)
add 0142ef8b95 [improvement](scanner) Supports bthread scanner (#16031)
No new revisions were added by this update.
Summary of changes:
be/CMakeLists.txt | 6 +
be/src/common/config.h | 4 +-
be/src/exprs/runtime_filter.cpp | 16 ++-
be/src/exprs/runtime_filter.h | 5 +-
.../io/cache/block/cached_remote_file_reader.cpp | 6 +-
be/src/io/cache/sub_file_cache.cpp | 12 ++
be/src/io/cache/sub_file_cache.h | 2 +
be/src/io/cache/whole_file_cache.cpp | 12 ++
be/src/io/cache/whole_file_cache.h | 2 +
be/src/io/fs/local_file_reader.cpp | 23 +++-
be/src/io/fs/local_file_reader.h | 2 +
be/src/io/fs/local_file_system.cpp | 96 +++++++++++++++-
be/src/io/fs/local_file_system.h | 18 +++
be/src/io/fs/remote_file_system.cpp | 12 ++
be/src/io/fs/remote_file_system.h | 3 +
be/src/io/fs/s3_file_reader.cpp | 14 ++-
be/src/io/fs/s3_file_reader.h | 2 +
be/src/io/fs/s3_file_system.cpp | 95 ++++++++++++++-
be/src/io/fs/s3_file_system.h | 19 +++
be/src/olap/lru_cache.cpp | 12 +-
be/src/olap/lru_cache.h | 3 +-
be/src/olap/rowset/rowset.cpp | 4 +-
be/src/olap/rowset/rowset.h | 7 +-
be/src/olap/rowset/segment_v2/column_reader.h | 6 +-
be/src/olap/storage_policy.cpp | 4 +-
be/src/service/internal_service.cpp | 3 +
be/src/util/async_io.h | 106 +++++++++++++++++
be/src/util/blocking_priority_queue.hpp | 39 +++++--
be/src/util/lock.h | 100 ++++++++++++++++
be/src/util/once.h | 17 ++-
be/src/util/priority_thread_pool.hpp | 7 +-
be/src/util/priority_work_stealing_thread_pool.hpp | 3 +-
be/src/vec/exec/scan/scanner_context.cpp | 45 ++++----
be/src/vec/exec/scan/scanner_context.h | 20 ++--
be/src/vec/exec/scan/scanner_scheduler.cpp | 128 +++++++++++++++------
be/src/vec/exec/scan/vscan_node.cpp | 4 +-
be/src/vec/exec/scan/vscan_node.h | 3 +-
build.sh | 5 +
38 files changed, 752 insertions(+), 113 deletions(-)
create mode 100644 be/src/util/async_io.h
create mode 100644 be/src/util/lock.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
