This is an automated email from the ASF dual-hosted git repository.
xuyang pushed a change to branch struct-map-type
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 552c49e129 [fix] fix fe ut
omit a09024aab1 [fix] fix code for comment
omit 585e8f78e3 [fix](struct-type) remove-empty-line
omit 150a21c89d [bug](regression-test) fix array regression test
omit d331b47d0b [bug](struct-type) fix array type miss scale
omit 5ee0f570c6 [bug](struct-type) fix be ut and format
omit 97d5166178 [bug](struct-type) fix be ut and format
omit 07ced590e6 [bug](struct-type) fix be ut and format
omit 30bb6ce581 rebase master and fix compile error
omit 147b55b43c [fix](complex_type) fix clone_type_info function return
default scalar type (#16400)
omit 9169340881 [fix](map-type) fix compile error (#16413)
omit 5b2becf847 [Feature](map) add map type to doris (#15966)
omit b516afae8e [fix](struct-type) fix insert null and explain for struct
type (#16054)
omit d4b932ebd3 [fix](struct-type) select of struct return wrong result
(#16032)
omit cd8825c2fd [hotfix](struct-type) Fix type descriptor make array load
core (#16020)
omit 4f0bf4f8b4 [fix](struct-type) support struct type insert (#15941)
omit 20d377b850 [fix](struct-type) support to remove double or single quote
(#15977)
omit b4eda8f95d save (#15908)
omit 1516faeb8d save (#15906)
omit fe34af5317 [feature](struct-type) adjust the vexpr for struct type
(#15669)
omit bd002d62e9 [fix](struct-type) struct create fix and add more struct
codes (#15879)
omit 7012cf8918 [WIP](struct-type) support struct-type in vectorize engine
(#15665)
omit 3c831a393c [feature](struct-type) add the class ColumnStruct and class
DataTypeStruct implement (#14545)
omit ccd8adf1c6 [test] (test) test modify branch (#14375)
omit 355c7ec28a save
omit 99581f8cc4 test
add 531616b8ee [Fix](bucket)fix partition with no history data &&
AutoBucketUtilsTest (#16516)
add 0142ef8b95 [improvement](scanner) Supports bthread scanner (#16031)
add d52fab6316 [typo](docs)modified some text errors (#16544)
add 338277b748 [doc](flink-connector) Update the flink connector docs to
the latest (#14856)
add 21cdbec982 [fix](docs) fix some errors in docs (#16546)
add 646ba2cc88 [bugfix](scannode) 1. make rows_read correct 2. use single
scanner if has limit clause (#16473)
add 7d035486ad [Opt](vec) opt the fast execute logic to remove useless
function call (#16532)
add 4b093d1ef6 [Bug](point query) when prepared statement used
lazyEvaluateRangeLocations should clear bucketSeq2locations to avoid memleak
(#16531)
add e48a033338 [Bug](pipeline) Support projection in UnionSourceOperator
(#16525)
add ba4b6aa0c0 [hot-fix](cooldown) Fix unknown module cooldownJob when
load fe image #16545
add ab4c718478 [fix](iceberg) remove s3 default temporary credentials
#16543
add 851a3575ae [fix](regression case) exclude test_broker_load suite,
reopen after bug fix (#16554)
add 9090c5e4e5 [fix](docs) Fix memory & rowset count metrics (#16550)
add 539fd684e9 [improvement](filecache) use dynamic segment size to cache
remote file block (#16485)
add a038fdaec6 [Bug](pipeline) Fix bug in non-local exchange on pipeline
engine (#16463)
add 130b3599bc [Improvement](writer) make DeltaWriter close idempotent to
be more robust (#16558)
add 77b7b84c34 fix (#16322)
add 9f0fab8823 [typo](docs)Change the lowercase letters of the disk type
example to uppercase (#16557)
add 9464e964ef test
add d4b638630f save
add da52757dad [test] (test) test modify branch (#14375)
add 198e0b6d0f [feature](struct-type) add the class ColumnStruct and class
DataTypeStruct implement (#14545)
add c6621516cf [WIP](struct-type) support struct-type in vectorize engine
(#15665)
add b307c4cc92 [fix](struct-type) struct create fix and add more struct
codes (#15879)
add ca1bf0a5f6 [feature](struct-type) adjust the vexpr for struct type
(#15669)
add fb718ce19e save (#15906)
add c9cd4641a2 save (#15908)
add 0f9be0e3bc [fix](struct-type) support to remove double or single quote
(#15977)
add 381ccb1d52 [fix](struct-type) support struct type insert (#15941)
add aacbb79d23 [hotfix](struct-type) Fix type descriptor make array load
core (#16020)
add c94ff762c9 [fix](struct-type) select of struct return wrong result
(#16032)
add fbda784e36 [fix](struct-type) fix insert null and explain for struct
type (#16054)
add 3d4d1a13c0 [Feature](map) add map type to doris (#15966)
add d8c95217a4 [fix](map-type) fix compile error (#16413)
add 75bd917e2a [fix](complex_type) fix clone_type_info function return
default scalar type (#16400)
add 2d99c5d8f4 rebase master and fix compile error
add 569894f7c7 [bug](struct-type) fix be ut and format
add 3084f61ad7 [bug](struct-type) fix be ut and format
add cb81a84f91 [bug](struct-type) fix be ut and format
add 8af00eb719 [bug](struct-type) fix array type miss scale
add e6a2be5a0b [bug](regression-test) fix array regression test
add 731d4efeb1 [fix](struct-type) remove-empty-line
add df728611fe [fix] fix code for comment
add 555cea6db7 [fix] fix fe ut
add ba9088c4b1 fix regression-test core
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (552c49e129)
\
N -- N -- N refs/heads/struct-map-type (ba9088c4b1)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
be/CMakeLists.txt | 6 +
be/src/common/config.h | 8 +-
be/src/exprs/runtime_filter.cpp | 16 ++-
be/src/exprs/runtime_filter.h | 5 +-
.../io/cache/block/cached_remote_file_reader.cpp | 16 ++-
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/file_factory.cpp | 3 +-
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/delta_writer.cpp | 2 +-
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/pipeline/exec/exchange_sink_buffer.cpp | 127 +++++++++++++-------
be/src/pipeline/exec/exchange_sink_buffer.h | 17 ++-
be/src/pipeline/exec/union_source_operator.cpp | 24 ++--
be/src/pipeline/exec/union_source_operator.h | 2 +
be/src/runtime/fragment_mgr.cpp | 34 +-----
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 | 49 ++++----
be/src/vec/exec/scan/scanner_context.h | 20 ++--
be/src/vec/exec/scan/scanner_scheduler.cpp | 132 +++++++++++++++------
be/src/vec/exec/scan/vscan_node.cpp | 4 +-
be/src/vec/exec/scan/vscan_node.h | 17 ++-
be/src/vec/exec/scan/vscanner.cpp | 4 +-
be/src/vec/exec/scan/vscanner.h | 3 -
be/src/vec/exprs/vectorized_fn_call.cpp | 10 +-
be/src/vec/exprs/vectorized_fn_call.h | 1 +
be/src/vec/functions/function.h | 13 +-
be/src/vec/sink/vdata_stream_sender.cpp | 48 +++++++-
be/src/vec/sink/vdata_stream_sender.h | 62 +++++++++-
build.sh | 5 +
.../import/import-way/stream-load-manual.md | 4 -
docs/en/docs/data-table/data-partition.md | 2 +-
docs/en/docs/ecosystem/flink-doris-connector.md | 26 ++--
docs/en/docs/install/install-deploy.md | 6 +-
.../maint-monitor/monitor-metrics/metrics.md | 9 +-
docs/zh-CN/docs/benchmark/ssb.md | 2 +-
.../import/import-way/stream-load-manual.md | 4 -
docs/zh-CN/docs/ecosystem/flink-doris-connector.md | 23 ++--
docs/zh-CN/docs/faq/data-faq.md | 2 +-
docs/zh-CN/docs/install/install-deploy.md | 6 +-
.../main/java/org/apache/doris/catalog/Type.java | 12 +-
.../java/org/apache/doris/catalog/S3Resource.java | 3 -
.../doris/clone/DynamicPartitionScheduler.java | 11 +-
.../org/apache/doris/persist/meta/MetaReader.java | 5 +-
.../org/apache/doris/planner/OlapScanNode.java | 1 +
.../doris/common/util/AutoBucketUtilsTest.java | 4 +
regression-test/conf/regression-conf.groovy | 2 +-
.../pipeline/p0/conf/regression-conf.groovy | 4 +-
.../suites/query_p0/join/test_join.groovy | 3 +-
71 files changed, 1088 insertions(+), 292 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]
