This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch refactor_rf
in repository https://gitbox.apache.org/repos/asf/doris.git
discard c288298374a [test](ut) [test](ut) Increase the types coverage of
HybridSet/MinMax
discard baa7d78f232 use has_remote_target to represent mode and add bitmap
filter test
discard a943ac89805 [test](ut) Increase the types coverage of BloomFilterFunc
discard ec5cabeb27e update
discard 6c6033c0fc9 add some metrics
discard 36be8a583b0 [test](rf) Improve test about bloom filter func
discard d1953871c2e resolve conflict
discard 4b6720a4033 [test](bloom_filter_func) add case about algorithm
discard 9d710a686f7 [test](ut) add ut for bloom filter and hybridset (#48698)
discard c51219ca78c add rpc fail test and eof test
discard 5e5a483be0f test RuntimeFilterMergeControllerEntity (#48678)
discard 5ee537f3007 test RuntimeFilterMgr (#48672)
discard db3ebf6a587 format (#48658)
discard 6e4173933d9 test (#48630)
discard 74bcdbc464c test rf utils (#48615)
discard 930566af3e0 add more ut of roles
discard aacd25e62dd test in or bloom (#48596)
discard a1be0a66487 fix UT (#48591)
discard 5eb01aa8779 fix compile fail and format
discard b804ee00000 [rf](ut) test minmax/bitmap filter (#48579)
discard 874718c29da fix coredump
discard 5640bdcf6d2 [runtime filter](UT) test bloom filter (#48575)
discard dbc4eacaa20 add more test and some fix
discard 9db838121b6 [runtime filter](UT) test in filter (#48562)
discard d9a559dc2f1 [refactor](runtime filter) Refine null property in runtime
filter (#48534)
discard d5817710883 some fix and add ut
discard 3e19f581b32 refactor of RuntimeFilterSlots
add d483293d98d [feat](doris compose) Add host mode for add remote fe
(#48839)
add bf46b16b00c [Refactor](function) Refactor function date floor/ceil by
removing interlayers (#47755)
add ada7ed7af47 [chore](BE) Remove test contents from src build (#48003)
add db3c740bd17 [feat](binlog) Add config to control whether enable
persistent connec… (#48761)
add bd1afe04105 [Refactor](type) Refactor misleading type descriptor
operator eq (#48529)
add df0f8d95976 [case](sc)add case as more level and rename before alter
(#48722)
add c432b79983a [feature](schema) support temporary table like mysql
(#40680)
add 802fcc9ce29 [fix](Prepared Statment) Fix exec prepared insert stmt in
non master error (#48689)
add 0813d701224 [test](beut) add pipeline DistinctStreamingAggOperator
beut (#48805)
add aa28ab984df [refactor](pipeline) refactor local merge sort operator
(#48360)
add 0c958d21467 [opt](mtmv) Opt materialized view rewrite performance when
the num of struct infos are huge (#48782)
add b836518488b [fix](group commit)Fix wal manager ut (#48789)
add 6e568af56b8 [improvement](fe) trim the start and end whitespace of
properties (#48710)
add 0d0e1714930 [chore](ga)To establish a CODEOWNERS mechanism for version
2.1: (#48869)
add 1e61228dc1b [fix](ut) fix cache evict in advance fluttering UT (#48858)
add 774f8f32b84 [fix](group commit) fix some group commit problem (#48621)
add 73c85928dc2 [fix](table) Breaking up dynamic partition table
scheduling consuming peak CPU consumption (#48577)
add 7094ee511af [feat](storage vault) Add object storage op check when
creating resource (#48073)
add 329d000e35b [fix](be/recycler) Fix S3RateLimiter bvar
`rate_limit_exceed_req_num` incorrectly
add d502f64eceb [fix](test) Remove incorrect checks for
light_schema_change (#48797)
add 34ef86e15e8 [fix](group commit) add some log to unstable
insert_group_commit_with_prepare_stmt case (#48470)
add 08549b77a8e [enhancement](schema-change) Cloud schema change do clean
up when job failed (#48426)
add 61389bb82e5 [improvement](statistics)Improve analyze partition column
and key column corner case. (#48757)
add 24de884d4de [test](beut) add pipeline RepeatOperator beut (#48849)
add 6ccf2cdce6d [chore](binlog) GetMeta returns dropped
partition/table/index commit seq (#48852)
add ed24ac3d270 [fix](udf) alias udf skip check enable_java_udf (#48843)
add 7a78b9d6719 [feature](inverted index) Add a basic tokenizer (#48716)
add eec8aedda3c [fix](Nereids) fix split part with delim not exist in
source string (#48895)
add 24b7b95f4d8 [fix](function) fix error result when STR_TO_DATE input
all space (#48872)
add ba3d0c7cde9 [Enhancement] (nereids) implement alterColumnStatsCommand
in nereids (#48628)
add 72c288920c2 [feature](cloud) Implement file cache microbench (#47563)
add a4c1b62c8dc [Feat](Nereids) refactor show table status command (#48875)
add 84d80e45632 [Refine](segment) Fix potential data race on
std::shared_ptr (#48884)
add e32406c40b0 [chore](profile) Add checker for profile level (#48787)
add 25ac68e2319 [opt](metrics) More precise task execution and wait worker
time (#48750)
add 7b94ac70090 [fix](doris compose) fix network sometimes failed (#48898)
add 3391d1ab23b [fix](test) fix duplicate variable define (#48939)
add 74c8eed5695 [fix](replica num) Fix the decrease in the number of
replicas and une… (#48704)
add 9855f797396 [ut](datatype) Add BE UT for some basic data types and
serializers (#48788)
add 56fa9fe24b4 [feat](catalog) support drop database force in external
catalog (#48943)
add 025e474ad5e [fix](information_schema) The time type in tables under
the information_schema should change according to the time_zone. (#48462)
add 5e47a50e264 [test](beut) add pipeline ExchangeSourceOperator beut
(#48938)
add 0e5abe8180a [fix](nereids) fix colocate agg + join compute wrong
result (#48934)
add 67db2646672 [Fix](cloud) Should not skip to calculate delete bitmaps
in publish phase if cache miss when get delete bitmap (#48867)
add 293b8094018 [Opt](log) Add more delete bitmap log for merge-on-write
table (#48930)
add bf50dd5d52f [fix](binlog) Wrong judgment of anyEnable for add binlog
(#48919)
add 542366f4b31 [fix](case) fix udf cases (#48969)
add 74ad0e34b57 [fix](sql cache) fix prepare statement with sql cache
throw NullPointerException (#48902)
add dc74f681d8f [opt](inverted index) uniform profile naming convention
(#48826)
add dc56640b995 [opt](inverted index) fix compile warning in compound
reader (#48890)
add b982b148682 [fix](variant) update least common type in
ColumnObject::pop_back (#48935)
add 53a14d0389d [Improvement]Add query start datetime (#48906)
add 30a10e6ebe8 [opt](paimon)Add suppressed information display (#48947)
add c46d4e79e95 [Feature](function) support year of week (#48870)
add 5550ce04c08 [fix](Nereids) deep copy for LogicalWindow is wrong
(#48861)
add 3806b97f243 [fix](mtmv) Fix nest mtmv rewrite fail when bottom mtmv
cache is invalid (#48222)
add 1062a765ec9 [fix](cloud) dup FDCache reset before FileCache dtor
causing crash (#48915)
add 284f3d1ee28 [Fix](cloud) Fix dup key problem when
`enable_new_tablet_do_compaction=true` (#48399)
add d0a82ae4667 [test](mtmv) Fix regression test not stable and add log
for debug (#48483)
add 0137cb8be6c [improve](binlog) Allow commit txn without waiting txn
publish (#48961)
add df0efda6ba0 [fix](ut) fix be decimal ut (#49003)
add 481867dadfb [fix](hudi) replace non thread safe SimpleDateFormat
(#48923)
add 675d73a5530 [opt](nereids) set column stats unkown by default when
derive Not expressoin (#48864)
add a9921a22225 [Feat](Nereids) support show views command (#48905)
add 753cc3ea432 [fix](Nereids) fix substring with only one parameter
(#48957)
add 26c02f440e0 [Feat](Nereids) support show tabletId command (#48815)
add 480a8ade4b9 [Fix](sc) Don't save base tablet's compaction jobs to new
tablet's `TabletJobInfoPB` (#48960)
add 88d52267e6e [feat](load) stream load supports loading JSON compressed
format (#48990)
add 678f1791dcf [improve](routine load) introduce routine load abnormal
job monitor metrics (#48171)
add be9288352a9 [fix][cloud] Prevent fe CloudReplica.getBackendIdImpl
consuming too much CPU when high-frequency stream loads (#48564)
add 601d24355b6 [test](beut) add pipeline SortOperator beut (#48912)
add 98b715a1d32 [feat](nereids) derive operative slots (#48738)
add 90d96f1112b [improve](binlog) Add and adjust result for get_lag
(#48953)
add 925a73a7a92 [fix](fragment) Remove unused instance ID (#49059)
add 1a450a2d778 [Opt](exec) opt variant column in join op (#49049)
add 61d36a3c31b [Fix](function) Fix wrong FE fold constant implementation
of function date_format (#49032)
add 4b931c088db [fix](group commit)Fix ut WalManagerTest (#49075)
add 74e3228480d [fix](nereids)fix the cascadesContext.getMemo()==null
(#48771)
add f86723a3e9c [feat](binlog) filter the async mv binlogs (#49028)
add f0b1cefda3d [opt](segment) SegmentFooterPB cache (#48924)
add 8244ecedd9e [fix](load) return DataQualityError when filtered rows
exceeds limit (#47617)
add 093388f6ff9 [fix](nereids) fix convert to date literal throw exception
(#48980)
add 95e68501cc8 [fix](statistics)The column name should be case sensitive
when inject column stats. (#48812)
add a674cf177ee [fix](fe) Fix non-master get image failed in k8s (#49072)
add b0f51617b15 [fix](regression-test) fix unstable case
test_hive_orc_predicate (#49088)
add 78b9344d97f [opt](meta) Add strict field synchronization checks for
cloud/non-cloud mode metadata conversions to prevent inconsistent PB bugs
(#48837)
add 2ff416e92ab [improve](mow) improve mow get_agg by cache (#48968)
add 5f47b8916f8 [fix](hudi) Fix Memory Leak in BitCaskDiskMap Due to
Circular Reference (#48955)
add f5e3fcd43e5 [Fix](nereids) fix test test_alter_table_set_column_stats
(#49107)
add 6c1d87078af [fix](memory) Fix LRUCachePolicy initialization and
registration order (#49117)
add bcaec127779 [Enhancement](paimon)support native read paimon top level
schema change table. (#48723)
add 2c0e49f0252 [Enhancement](nereids)support show backup (#48818)
add ee8685badd5 [fix](multi table load) error URL does not depend on the
value of _number_filtered_rows (#49111)
add 56668844eab [Improvement]Add dummy workload group (#48986)
add e18ea534d9a [improve](information schema) introduce routine load job
system table (#48963)
add 2a2b22967ae [fix] (streamload) fixed the issue of data loss due to
concurrency when importing data from streamload (#48948)
add 6b6acf53a54 [Improment]Add ComputeGroupMgr (#48187)
add 744ad806916 [fix](regression) Avoid defined global variables in
backup-restore case script (#49102)
add 0f7cfb07916 [Minor](Nereids) rename MAX_MIN_FILTER_PUSH_DOWN to
PUSH_DOWN_MAX_MIN_FILTER (#48840)
add e9cef9e71f9 [test](beut) add pipeline UnionOperator beut (#48984)
add 1e872ff2a1f [improve](analytic) refactor the insert into result mode
for window function (#48883)
add 47e898d1c03 [Fix](cloud) Should not remove pending delete bitmaps when
`update_delete_bitmap` in txn load if the txn is not the first sub txns (#49046)
add 2a4d721d530 [refactor](udf) refactor udf datatype to simplify logic
(#48932)
add 88530bba847 [be](ut) fix be ut test invalid case failed (#48928)
add e1262bd3347 [fix](group commit)Fix replay wal fail problem on agg
state type (#49081)
add da4294b4f35 [Fix](log) Fix some delete bitmap log (#49009)
add ac5c37cc199 [Fix](partial update) use correct default value for
missing columns in partial update (#49066)
add 5884b61f7c4 [fix](Nereids) fold str_to_date to wrong result when
parameter out of range (#49033)
add 03771221f2f [Test](nereids) add ut for show system command and remove
unuse function (#48981)
add 083af74c255 [test](ut) add cases about partitioned aggregation
operators (#48925)
add 6d6c66e7dc4 [fix](Nereids) initcap constant folding should upper first
character in all words (#49061)
add 171053f5a6f [fix](array/map) Fix BE crash in lambda functions (#49140)
add 7633d8c6356 [Enhancement] (nereids) Implement showIndexStatsCommand in
nereids (#48835)
add 8d6d952fe7c [fix](nereids) fix to_monday('1970-01-04 23:59:59')
(#49153)
add ad7bae609aa [fix](function) fix erroe result with utf8 in function
Overlay (#49105)
add 65a26a41140 [fix](arrow) Fix UT DataTypeSerDeArrowTest of
Array/Map/Struct/Bitmap/HLL/Decimal256 types (#48944)
add 054e042ee56 refactor of RuntimeFilterSlots
add 96cc84ea0de some fix and add ut
add 0f1825a0a07 [refactor](runtime filter) Refine null property in runtime
filter (#48534)
add 1858366f25d [runtime filter](UT) test in filter (#48562)
add 2a7cfde0b24 add more test and some fix
add 8f910d090ca [runtime filter](UT) test bloom filter (#48575)
add 656e6299327 fix coredump
add ac11b4e1102 [rf](ut) test minmax/bitmap filter (#48579)
add a0c49241db4 fix compile fail and format
add ad37379c709 fix UT (#48591)
add 01e2df0d15d test in or bloom (#48596)
add 613e688adab add more ut of roles
add 9434341fa8a test rf utils (#48615)
add 1bd085b407f test (#48630)
add fed6d1f20b8 format (#48658)
add 1efc5966a24 test RuntimeFilterMgr (#48672)
add 8b812980d29 test RuntimeFilterMergeControllerEntity (#48678)
add ce1cd932b7c add rpc fail test and eof test
add 52c4d3e8290 [test](ut) add ut for bloom filter and hybridset (#48698)
add 4e841055c8b [test](bloom_filter_func) add case about algorithm
add 7f2de0b8f9d resolve conflict
add d559a03dc14 [test](rf) Improve test about bloom filter func
add 2cfda697557 add some metrics
add 6adf36c8504 [test](ut) Increase the types coverage of BloomFilterFunc
add d6e5a1fc49c use has_remote_target to represent mode and add bitmap
filter test
add 14e832bacf6 [test](ut) [test](ut) Increase the types coverage of
HybridSet/MinMax
add 22d2aced042 add lock for producer set state
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 (c288298374a)
\
N -- N -- N refs/heads/refactor_rf (22d2aced042)
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:
.asf.yaml | 6 +-
.licenserc.yaml | 2 +
be/CMakeLists.txt | 13 +-
be/src/agent/task_worker_pool.cpp | 80 +-
be/src/cloud/cloud_compaction_stop_token.cpp | 125 ++
.../cloud_compaction_stop_token.h} | 37 +-
.../cloud/cloud_cumulative_compaction_policy.cpp | 7 +-
be/src/cloud/cloud_meta_mgr.cpp | 47 +-
be/src/cloud/cloud_meta_mgr.h | 3 +-
be/src/cloud/cloud_schema_change_job.cpp | 19 +
be/src/cloud/cloud_schema_change_job.h | 2 +
be/src/cloud/cloud_storage_engine.cpp | 64 +
be/src/cloud/cloud_storage_engine.h | 8 +
be/src/cloud/cloud_tablet.cpp | 34 +-
be/src/cloud/cloud_txn_delete_bitmap_cache.cpp | 16 +-
be/src/cloud/pb_convert.cpp | 118 +-
be/src/cloud/pb_convert.h | 12 +-
be/src/common/config.cpp | 5 +
be/src/common/config.h | 5 +
be/src/common/exception.cpp | 5 +
be/src/exec/schema_scanner.cpp | 6 +-
be/src/exec/schema_scanner.h | 4 +-
.../schema_active_queries_scanner.cpp | 1 +
.../schema_backend_kerberos_ticket_cache.cpp | 1 -
.../schema_backend_kerberos_ticket_cache.h | 2 -
be/src/exec/schema_scanner/schema_helper.cpp | 9 +
be/src/exec/schema_scanner/schema_helper.h | 6 +
.../schema_scanner/schema_partitions_scanner.cpp | 1 +
.../schema_scanner/schema_processlist_scanner.cpp | 1 +
.../schema_routine_load_job_scanner.cpp | 199 ++
...t_cache.h => schema_routine_load_job_scanner.h} | 25 +-
.../exec/schema_scanner/schema_rowsets_scanner.cpp | 5 +-
.../exec/schema_scanner/schema_tables_scanner.cpp | 7 +-
be/src/http/action/stream_load.cpp | 11 +-
be/src/io/fs/multi_table_pipe.cpp | 5 +-
be/src/io/tools/CMakeLists.txt | 68 +
{gensrc => be/src/io/tools}/Makefile | 0
be/src/io/tools/file_cache_microbench.cpp | 2354 ++++++++++++++++++++
be/src/io/tools/proto/Makefile | 38 +
.../tools/proto/microbench.proto} | 34 +-
be/src/io/tools/readme.md | 133 ++
be/src/olap/base_tablet.cpp | 16 +-
be/src/olap/data_dir.cpp | 38 +-
be/src/olap/inverted_index_parser.cpp | 4 +
be/src/olap/inverted_index_parser.h | 4 +-
be/src/olap/inverted_index_profile.h | 4 +-
be/src/olap/memtable_flush_executor.cpp | 2 +-
be/src/olap/memtable_flush_executor.h | 2 +
be/src/olap/page_cache.cpp | 85 +-
be/src/olap/page_cache.h | 78 +-
be/src/olap/partial_update_info.cpp | 6 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 4 +-
be/src/olap/rowset/rowset.cpp | 9 +
.../inverted_index/analyzer/analyzer.cpp | 5 +-
.../{icu/ICUAnalyzer.h => basic/basic_analyzer.h} | 25 +-
.../analyzer/basic/basic_tokenizer.cpp | 108 +
.../ICUTokenizer.h => basic/basic_tokenizer.h} | 24 +-
...ratorWrapper.cpp => break_iterator_wrapper.cpp} | 6 +-
...kIteratorWrapper.h => break_iterator_wrapper.h} | 2 +-
...akIterator.cpp => composite_break_iterator.cpp} | 2 +-
...eBreakIterator.h => composite_break_iterator.h} | 8 +-
...Config.cpp => default_icu_tokenizer_config.cpp} | 2 +-
...izerConfig.h => default_icu_tokenizer_config.h} | 2 +-
.../analyzer/icu/{ICUAnalyzer.h => icu_analyzer.h} | 2 +-
.../analyzer/icu/{ICUCommon.h => icu_common.h} | 0
.../icu/{ICUTokenizer.cpp => icu_tokenizer.cpp} | 2 +-
.../icu/{ICUTokenizer.h => icu_tokenizer.h} | 6 +-
...ICUTokenizerConfig.h => icu_tokenizer_config.h} | 2 +-
.../{ScriptIterator.cpp => script_iterator.cpp} | 2 +-
.../icu/{ScriptIterator.h => script_iterator.h} | 2 +-
.../segment_v2/inverted_index_compound_reader.cpp | 32 +-
.../segment_v2/inverted_index_compound_reader.h | 2 +-
be/src/olap/rowset/segment_v2/page_io.cpp | 2 +
be/src/olap/rowset/segment_v2/segment.cpp | 87 +-
be/src/olap/rowset/segment_v2/segment.h | 10 +-
be/src/olap/rowset_builder.cpp | 10 +-
be/src/olap/tablet_meta.cpp | 60 +-
be/src/olap/tablet_meta.h | 7 +
be/src/olap/tablet_schema.cpp | 8 +-
be/src/olap/tablet_schema.h | 8 +-
be/src/olap/wal/wal_manager.cpp | 4 +
be/src/pipeline/dependency.h | 79 +-
be/src/pipeline/exec/aggregation_source_operator.h | 3 +-
be/src/pipeline/exec/analytic_sink_operator.cpp | 77 +-
be/src/pipeline/exec/analytic_sink_operator.h | 11 +-
.../distinct_streaming_aggregation_operator.cpp | 88 +-
.../exec/distinct_streaming_aggregation_operator.h | 20 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 14 -
be/src/pipeline/exec/exchange_sink_operator.h | 2 -
be/src/pipeline/exec/exchange_source_operator.cpp | 22 +-
be/src/pipeline/exec/exchange_source_operator.h | 15 +-
.../exec/group_commit_block_sink_operator.cpp | 14 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 15 +-
be/src/pipeline/exec/hashjoin_build_sink.h | 3 +
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 9 +-
be/src/pipeline/exec/hashjoin_probe_operator.h | 3 +
.../exec/join/process_hash_table_probe_impl.h | 4 +
.../exec/local_merge_sort_source_operator.cpp | 159 ++
.../exec/local_merge_sort_source_operator.h | 117 +
be/src/pipeline/exec/operator.cpp | 2 +
be/src/pipeline/exec/operator.h | 3 +
.../exec/partitioned_aggregation_sink_operator.cpp | 7 +-
.../exec/partitioned_aggregation_source_operator.h | 3 +-
be/src/pipeline/exec/repeat_operator.cpp | 100 +-
be/src/pipeline/exec/repeat_operator.h | 8 +-
be/src/pipeline/exec/schema_scan_operator.cpp | 2 +-
be/src/pipeline/exec/sort_sink_operator.cpp | 6 +-
be/src/pipeline/exec/sort_sink_operator.h | 10 +
be/src/pipeline/exec/sort_source_operator.cpp | 22 +-
be/src/pipeline/exec/sort_source_operator.h | 20 +-
be/src/pipeline/exec/union_sink_operator.cpp | 64 +-
be/src/pipeline/exec/union_sink_operator.h | 61 +-
be/src/pipeline/exec/union_source_operator.cpp | 101 +-
be/src/pipeline/exec/union_source_operator.h | 59 +-
.../local_exchange/local_exchange_sink_operator.h | 2 -
.../local_exchange_source_operator.cpp | 28 +-
.../local_exchange_source_operator.h | 7 -
be/src/pipeline/local_exchange/local_exchanger.cpp | 125 +-
be/src/pipeline/local_exchange/local_exchanger.h | 40 -
be/src/pipeline/pipeline_fragment_context.cpp | 28 +-
be/src/runtime/descriptors.h | 2 +-
be/src/runtime/exec_env_init.cpp | 1 -
be/src/runtime/fragment_mgr.cpp | 12 +-
be/src/runtime/group_commit_mgr.cpp | 2 +
be/src/runtime/memory/cache_policy.cpp | 1 -
be/src/runtime/memory/lru_cache_policy.h | 2 +
be/src/runtime/query_context.cpp | 10 +-
be/src/runtime/query_context.h | 5 -
be/src/runtime/runtime_state.cpp | 8 +-
be/src/runtime/runtime_state.h | 7 +-
be/src/runtime/types.h | 20 +-
.../workload_group/dummy_workload_group.cpp | 41 +
.../dummy_workload_group.h} | 44 +-
be/src/runtime/workload_group/workload_group.cpp | 4 +-
be/src/runtime/workload_group/workload_group.h | 17 +-
.../workload_group/workload_group_manager.cpp | 10 +
.../workload_group/workload_group_manager.h | 15 +-
.../workload_group/workload_group_metrics.h | 2 +
be/src/runtime/workload_management/io_throttle.h | 2 +
be/src/runtime_filter/runtime_filter_producer.h | 4 +
be/src/runtime_filter/runtime_filter_wrapper.cpp | 6 +-
be/src/runtime_filter/runtime_filter_wrapper.h | 5 +-
be/src/service/backend_service.cpp | 33 +-
be/src/util/date_func.cpp | 4 +-
be/src/util/load_util.cpp | 24 +
be/src/util/s3_util.cpp | 18 +-
be/src/util/threadpool.cpp | 22 +-
be/src/util/threadpool.h | 6 +-
.../vec/aggregate_functions/aggregate_function.h | 13 +
.../aggregate_function_window.h | 79 +-
be/src/vec/columns/column.h | 26 -
be/src/vec/columns/column_array.cpp | 1 +
be/src/vec/columns/column_const.h | 2 +
be/src/vec/columns/column_decimal.cpp | 10 +-
be/src/vec/columns/column_dictionary.h | 17 -
be/src/vec/columns/column_fixed_length_object.h | 1 +
be/src/vec/columns/column_map.cpp | 1 +
be/src/vec/columns/column_nullable.h | 2 +
be/src/vec/columns/column_object.cpp | 27 +-
be/src/vec/columns/column_object.h | 80 -
be/src/vec/columns/column_string.cpp | 10 +-
be/src/vec/columns/column_string.h | 20 +-
be/src/vec/columns/column_struct.cpp | 1 +
be/src/vec/columns/column_vector.cpp | 3 +-
be/src/vec/columns/column_vector.h | 6 +-
be/src/vec/columns/predicate_column.h | 19 -
be/src/vec/common/hash_table/hash_map_context.h | 2 +-
be/src/vec/common/sort/sorter.h | 9 +
be/src/vec/core/block.h | 6 -
be/src/vec/core/decimal_comparison.h | 4 +-
be/src/vec/data_types/data_type_decimal.h | 34 +-
be/src/vec/data_types/data_type_number.h | 2 +
be/src/vec/data_types/data_type_time_v2.h | 4 +-
.../serde/data_type_datetimev2_serde.cpp | 5 +-
.../data_types/serde/data_type_datev2_serde.cpp | 7 +-
.../data_types/serde/data_type_decimal_serde.cpp | 43 +-
.../vec/data_types/serde/data_type_decimal_serde.h | 9 +-
.../vec/data_types/serde/data_type_ipv6_serde.cpp | 16 +-
.../data_types/serde/data_type_number_serde.cpp | 30 +-
.../vec/data_types/serde/data_type_string_serde.h | 2 +
be/src/vec/exec/format/csv/csv_reader.cpp | 21 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 57 +-
.../exec/format/parquet/parquet_column_convert.cpp | 66 +-
be/src/vec/exec/format/table/paimon_reader.cpp | 87 +-
be/src/vec/exec/format/table/paimon_reader.h | 55 +
be/src/vec/exec/scan/file_scanner.cpp | 36 +-
.../exprs/lambda_function/varray_map_function.cpp | 10 +-
be/src/vec/exprs/vliteral.h | 4 +
.../vec/functions/array/function_array_element.h | 5 +-
be/src/vec/functions/date_time_transforms.h | 17 +-
.../vec/functions/function_datetime_floor_ceil.cpp | 1093 ++++-----
be/src/vec/functions/function_string.h | 154 +-
be/src/vec/functions/to_time_function.cpp | 10 +-
be/src/vec/runtime/vdata_stream_recvr.h | 12 +-
be/src/vec/runtime/vdatetime_value.cpp | 46 +-
be/src/vec/runtime/vdatetime_value.h | 36 +-
be/src/vec/sink/vmysql_result_writer.cpp | 8 +-
be/src/vec/sink/vrow_distribution.cpp | 18 +-
be/src/vec/sink/vtablet_block_convertor.cpp | 49 +-
be/src/vec/sink/vtablet_block_convertor.h | 11 +-
be/src/vec/sink/vtablet_finder.cpp | 16 +-
be/src/vec/sink/vtablet_finder.h | 4 +-
be/src/vec/sink/writer/async_result_writer.cpp | 56 +-
be/src/vec/utils/util.hpp | 2 +-
be/test/agent/heartbeat_server_test.cpp | 2 +-
be/test/data/vec/columns/BIGINT.csv | 85 +
be/test/data/vec/columns/BIGINT_UNSIGNED.csv | 79 +
be/test/data/vec/columns/DATETIMEV1.csv | 21 +
be/test/data/vec/columns/DATETIMEV2(0).csv | 21 +
be/test/data/vec/columns/DATETIMEV2(5).csv | 21 +
be/test/data/vec/columns/DATETIMEV2(6).csv | 21 +
be/test/data/vec/columns/DATEV1.csv | 21 +
be/test/data/vec/columns/DATEV2.csv | 21 +
be/test/data/vec/columns/DECIMALV2(27,9).csv | 1340 +++++++++++
be/test/data/vec/columns/DECIMALV3(1,0).csv | 58 +
be/test/data/vec/columns/DECIMALV3(1,1).csv | 58 +
be/test/data/vec/columns/DECIMALV3(10,5).csv | 57 +
be/test/data/vec/columns/DECIMALV3(18,0).csv | 133 ++
be/test/data/vec/columns/DECIMALV3(18,18).csv | 203 ++
be/test/data/vec/columns/DECIMALV3(18,9).csv | 1341 +++++++++++
be/test/data/vec/columns/DECIMALV3(27,9).csv | 41 +
be/test/data/vec/columns/DECIMALV3(38,0).csv | 132 ++
be/test/data/vec/columns/DECIMALV3(38,30).csv | 1384 ++++++++++++
be/test/data/vec/columns/DECIMALV3(38,38).csv | 203 ++
be/test/data/vec/columns/DECIMALV3(76,0).csv | 137 ++
be/test/data/vec/columns/DECIMALV3(76,38).csv | 544 +++++
be/test/data/vec/columns/DECIMALV3(76,76).csv | 119 +
be/test/data/vec/columns/DECIMALV3(8,3).csv | 7 +
be/test/data/vec/columns/DECIMALV3(9,0).csv | 69 +
be/test/data/vec/columns/DECIMALV3(9,9).csv | 53 +
be/test/data/vec/columns/DICT_INDICES.csv | 100 +
be/test/data/vec/columns/DICT_STR.csv | 34 +
be/test/data/vec/columns/DOUBLE.csv | 36 +
be/test/data/vec/columns/FLOAT.csv | 18 +
be/test/data/vec/columns/INT.csv | 79 +
be/test/data/vec/columns/INT_UNSIGNED.csv | 87 +
be/test/data/vec/columns/LARGEINT.csv | 79 +
be/test/data/vec/columns/LARGEINT_UNSIGNED.csv | 74 +
be/test/data/vec/columns/SMALLINT.csv | 85 +
be/test/data/vec/columns/SMALLINT_UNSIGNED.csv | 75 +
be/test/data/vec/columns/STRING.csv | 34 +
be/test/data/vec/columns/TIMEV2(6).csv | 58 +
be/test/data/vec/columns/TINYINT.csv | 83 +
be/test/data/vec/columns/TINYINT_UNSIGNED.csv | 79 +
.../column_date_v1_update_crc_with_value.out | Bin 0 -> 49 bytes
..._date_v1_update_crc_with_value.out_with_nullmap | 1 +
.../column_date_v1_update_crcs_with_value.out | Bin 0 -> 244 bytes
...date_v1_update_crcs_with_value.out_with_nullmap | 1 +
.../column_date_v1_update_hashes_with_value.out | Bin 0 -> 438 bytes
...te_v1_update_hashes_with_value.out_with_nullmap | 1 +
.../column_date_v1_update_sip_hash_with_value.out | Bin 0 -> 60 bytes
.../column_date_v1_update_xxHash_with_value.out | Bin 0 -> 59 bytes
...te_v1_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_date_v2_update_crc_with_value.out | Bin 0 -> 47 bytes
..._date_v2_update_crc_with_value.out_with_nullmap | 1 +
.../column_date_v2_update_crcs_with_value.out | Bin 0 -> 238 bytes
...date_v2_update_crcs_with_value.out_with_nullmap | 1 +
.../column_date_v2_update_hashes_with_value.out | Bin 0 -> 437 bytes
...te_v2_update_hashes_with_value.out_with_nullmap | 1 +
.../column_date_v2_update_sip_hash_with_value.out | Bin 0 -> 59 bytes
.../column_date_v2_update_xxHash_with_value.out | Bin 0 -> 58 bytes
...te_v2_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_datetime_v1_update_crc_with_value.out | Bin 0 -> 50 bytes
...etime_v1_update_crc_with_value.out_with_nullmap | 1 +
.../column_datetime_v1_update_crcs_with_value.out | Bin 0 -> 243 bytes
...time_v1_update_crcs_with_value.out_with_nullmap | 1 +
...column_datetime_v1_update_hashes_with_value.out | Bin 0 -> 431 bytes
...me_v1_update_hashes_with_value.out_with_nullmap | 1 +
...lumn_datetime_v1_update_sip_hash_with_value.out | Bin 0 -> 60 bytes
...column_datetime_v1_update_xxHash_with_value.out | Bin 0 -> 59 bytes
...me_v1_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_datetime_v2_0_update_crc_with_value.out | Bin 0 -> 51 bytes
...ime_v2_0_update_crc_with_value.out_with_nullmap | 1 +
...column_datetime_v2_0_update_crcs_with_value.out | Bin 0 -> 245 bytes
...me_v2_0_update_crcs_with_value.out_with_nullmap | 1 +
...lumn_datetime_v2_0_update_hashes_with_value.out | Bin 0 -> 442 bytes
..._v2_0_update_hashes_with_value.out_with_nullmap | 1 +
...mn_datetime_v2_0_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
...lumn_datetime_v2_0_update_xxHash_with_value.out | Bin 0 -> 61 bytes
..._v2_0_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_datetime_v2_5_update_crc_with_value.out | Bin 0 -> 51 bytes
...ime_v2_5_update_crc_with_value.out_with_nullmap | 1 +
...column_datetime_v2_5_update_crcs_with_value.out | Bin 0 -> 242 bytes
...me_v2_5_update_crcs_with_value.out_with_nullmap | 1 +
...lumn_datetime_v2_5_update_hashes_with_value.out | Bin 0 -> 435 bytes
..._v2_5_update_hashes_with_value.out_with_nullmap | 1 +
...mn_datetime_v2_5_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
...lumn_datetime_v2_5_update_xxHash_with_value.out | Bin 0 -> 61 bytes
..._v2_5_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_datetime_v2_6_update_crc_with_value.out | Bin 0 -> 50 bytes
...ime_v2_6_update_crc_with_value.out_with_nullmap | 1 +
...column_datetime_v2_6_update_crcs_with_value.out | Bin 0 -> 241 bytes
...me_v2_6_update_crcs_with_value.out_with_nullmap | 1 +
...lumn_datetime_v2_6_update_hashes_with_value.out | Bin 0 -> 437 bytes
..._v2_6_update_hashes_with_value.out_with_nullmap | 1 +
...mn_datetime_v2_6_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
...lumn_datetime_v2_6_update_xxHash_with_value.out | Bin 0 -> 61 bytes
..._v2_6_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_decimal128_1_update_crc_with_value.out | Bin 0 -> 58 bytes
...mal128_1_update_crc_with_value.out_with_nullmap | 1 +
.../column_decimal128_1_update_crcs_with_value.out | Bin 0 -> 1461 bytes
...al128_1_update_crcs_with_value.out_with_nullmap | 1 +
...olumn_decimal128_1_update_hashes_with_value.out | Bin 0 -> 2734 bytes
...128_1_update_hashes_with_value.out_with_nullmap | 1 +
...umn_decimal128_1_update_sip_hash_with_value.out | Bin 0 -> 68 bytes
...olumn_decimal128_1_update_xxHash_with_value.out | Bin 0 -> 68 bytes
...128_1_update_xxHash_with_value.out_with_nullmap | 1 +
...column_decimal128v2_1_update_crc_with_value.out | Bin 0 -> 59 bytes
...l128v2_1_update_crc_with_value.out_with_nullmap | 1 +
...umn_decimal128v2_1_update_hashes_with_value.out | Bin 0 -> 27392 bytes
...8v2_1_update_hashes_with_value.out_with_nullmap | 1 +
...n_decimal128v2_1_update_sip_hash_with_value.out | Bin 0 -> 69 bytes
...umn_decimal128v2_1_update_xxHash_with_value.out | Bin 0 -> 69 bytes
...8v2_1_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_decimal256_1_update_crc_with_value.out | Bin 0 -> 54 bytes
...mal256_1_update_crc_with_value.out_with_nullmap | 1 +
.../column_decimal256_1_update_crcs_with_value.out | Bin 0 -> 1484 bytes
...al256_1_update_crcs_with_value.out_with_nullmap | 1 +
...olumn_decimal256_1_update_hashes_with_value.out | Bin 0 -> 2813 bytes
...256_1_update_hashes_with_value.out_with_nullmap | 1 +
...umn_decimal256_1_update_sip_hash_with_value.out | Bin 0 -> 66 bytes
...olumn_decimal256_1_update_xxHash_with_value.out | Bin 0 -> 65 bytes
...256_1_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_decimal32_1_update_crc_with_value.out | Bin 0 -> 54 bytes
...imal32_1_update_crc_with_value.out_with_nullmap | 1 +
.../column_decimal32_1_update_crcs_with_value.out | Bin 0 -> 641 bytes
...mal32_1_update_crcs_with_value.out_with_nullmap | 1 +
...column_decimal32_1_update_hashes_with_value.out | Bin 0 -> 1217 bytes
...l32_1_update_hashes_with_value.out_with_nullmap | 1 +
...lumn_decimal32_1_update_sip_hash_with_value.out | Bin 0 -> 62 bytes
...column_decimal32_1_update_xxHash_with_value.out | Bin 0 -> 63 bytes
...l32_1_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_decimal64_1_update_crc_with_value.out | Bin 0 -> 54 bytes
...imal64_1_update_crc_with_value.out_with_nullmap | 1 +
.../column_decimal64_1_update_crcs_with_value.out | Bin 0 -> 1456 bytes
...mal64_1_update_crcs_with_value.out_with_nullmap | 1 +
...column_decimal64_1_update_hashes_with_value.out | Bin 0 -> 2720 bytes
...l64_1_update_hashes_with_value.out_with_nullmap | 1 +
...lumn_decimal64_1_update_sip_hash_with_value.out | Bin 0 -> 65 bytes
...column_decimal64_1_update_xxHash_with_value.out | Bin 0 -> 64 bytes
...l64_1_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_float32_update_crc_with_value.out | Bin 0 -> 51 bytes
..._float32_update_crc_with_value.out_with_nullmap | 1 +
.../column_float32_update_hashes_with_value.out | Bin 0 -> 314 bytes
...oat32_update_hashes_with_value.out_with_nullmap | 1 +
.../column_float32_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
.../column_float32_update_xxHash_with_value.out | Bin 0 -> 62 bytes
...oat32_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_float64_update_crc_with_value.out | Bin 0 -> 51 bytes
..._float64_update_crc_with_value.out_with_nullmap | 1 +
.../column_float64_update_hashes_with_value.out | Bin 0 -> 684 bytes
...oat64_update_hashes_with_value.out_with_nullmap | 1 +
.../column_float64_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
.../column_float64_update_xxHash_with_value.out | Bin 0 -> 61 bytes
...oat64_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_int128_update_crc_with_value.out | Bin 0 -> 51 bytes
...n_int128_update_crc_with_value.out_with_nullmap | 1 +
.../column_int128_update_crcs_with_value.out | Bin 0 -> 867 bytes
..._int128_update_crcs_with_value.out_with_nullmap | 1 +
.../column_int128_update_hashes_with_value.out | Bin 0 -> 1615 bytes
...nt128_update_hashes_with_value.out_with_nullmap | 1 +
.../column_int128_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
.../column_int128_update_xxHash_with_value.out | Bin 0 -> 61 bytes
...nt128_update_xxHash_with_value.out_with_nullmap | 1 +
.../columns/column_int16_update_crc_with_value.out | Bin 0 -> 49 bytes
...mn_int16_update_crc_with_value.out_with_nullmap | 1 +
.../column_int16_update_crcs_with_value.out | Bin 0 -> 932 bytes
...n_int16_update_crcs_with_value.out_with_nullmap | 1 +
.../column_int16_update_hashes_with_value.out | Bin 0 -> 1740 bytes
...int16_update_hashes_with_value.out_with_nullmap | 1 +
.../column_int16_update_sip_hash_with_value.out | Bin 0 -> 58 bytes
.../column_int16_update_xxHash_with_value.out | Bin 0 -> 60 bytes
...int16_update_xxHash_with_value.out_with_nullmap | 1 +
.../columns/column_int32_update_crc_with_value.out | Bin 0 -> 50 bytes
...mn_int32_update_crc_with_value.out_with_nullmap | 1 +
.../column_int32_update_crcs_with_value.out | Bin 0 -> 872 bytes
...n_int32_update_crcs_with_value.out_with_nullmap | 1 +
.../column_int32_update_hashes_with_value.out | Bin 0 -> 1632 bytes
...int32_update_hashes_with_value.out_with_nullmap | 1 +
.../column_int32_update_sip_hash_with_value.out | Bin 0 -> 60 bytes
.../column_int32_update_xxHash_with_value.out | Bin 0 -> 60 bytes
...int32_update_xxHash_with_value.out_with_nullmap | 1 +
.../columns/column_int64_update_crc_with_value.out | Bin 0 -> 50 bytes
...mn_int64_update_crc_with_value.out_with_nullmap | 1 +
.../column_int64_update_crcs_with_value.out | Bin 0 -> 940 bytes
...n_int64_update_crcs_with_value.out_with_nullmap | 1 +
.../column_int64_update_hashes_with_value.out | Bin 0 -> 1744 bytes
...int64_update_hashes_with_value.out_with_nullmap | 1 +
.../column_int64_update_sip_hash_with_value.out | Bin 0 -> 59 bytes
.../column_int64_update_xxHash_with_value.out | Bin 0 -> 59 bytes
...int64_update_xxHash_with_value.out_with_nullmap | 1 +
.../columns/column_int8_update_crc_with_value.out | Bin 0 -> 48 bytes
...umn_int8_update_crc_with_value.out_with_nullmap | 1 +
.../columns/column_int8_update_crcs_with_value.out | Bin 0 -> 911 bytes
...mn_int8_update_crcs_with_value.out_with_nullmap | 1 +
.../column_int8_update_hashes_with_value.out | Bin 0 -> 1713 bytes
..._int8_update_hashes_with_value.out_with_nullmap | 1 +
.../column_int8_update_sip_hash_with_value.out | Bin 0 -> 59 bytes
.../column_int8_update_xxHash_with_value.out | Bin 0 -> 58 bytes
..._int8_update_xxHash_with_value.out_with_nullmap | 1 +
.../vec/columns/column_ip_update_crc_hashes.out | Bin 0 -> 271 bytes
.../column_ip_update_crc_hashes.out_with_nullmap | 2 +
.../columns/column_ip_update_hashes_with_value.out | Bin 0 -> 465 bytes
...mn_ip_update_hashes_with_value.out_with_nullmap | 2 +
.../column_ip_update_hashes_with_value1.out | Bin 0 -> 465 bytes
.../columns/column_str32_update_crc_with_value.out | Bin 0 -> 50 bytes
...mn_str32_update_crc_with_value.out_with_nullmap | 1 +
.../column_str32_update_crcs_with_value.out | Bin 0 -> 398 bytes
...n_str32_update_crcs_with_value.out_with_nullmap | 1 +
.../column_str32_update_hashes_with_value.out | Bin 0 -> 742 bytes
...str32_update_hashes_with_value.out_with_nullmap | 1 +
.../column_str32_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
.../column_str32_update_xxHash_with_value.out | Bin 0 -> 60 bytes
...str32_update_xxHash_with_value.out_with_nullmap | 1 +
.../columns/column_str64_update_crc_with_value.out | Bin 0 -> 50 bytes
...mn_str64_update_crc_with_value.out_with_nullmap | 1 +
.../column_str64_update_crcs_with_value.out | Bin 0 -> 398 bytes
...n_str64_update_crcs_with_value.out_with_nullmap | 1 +
.../column_str64_update_hashes_with_value.out | Bin 0 -> 742 bytes
...str64_update_hashes_with_value.out_with_nullmap | 1 +
.../column_str64_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
.../column_str64_update_xxHash_with_value.out | Bin 0 -> 60 bytes
...str64_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_uint16_update_crc_with_value.out | Bin 0 -> 51 bytes
...n_uint16_update_crc_with_value.out_with_nullmap | 1 +
.../column_uint16_update_crcs_with_value.out | Bin 0 -> 827 bytes
..._uint16_update_crcs_with_value.out_with_nullmap | 1 +
.../column_uint16_update_hashes_with_value.out | Bin 0 -> 1539 bytes
...int16_update_hashes_with_value.out_with_nullmap | 1 +
.../column_uint16_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
.../column_uint16_update_xxHash_with_value.out | Bin 0 -> 61 bytes
...int16_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_uint32_update_crc_with_value.out | Bin 0 -> 49 bytes
...n_uint32_update_crc_with_value.out_with_nullmap | 1 +
.../column_uint32_update_crcs_with_value.out | Bin 0 -> 949 bytes
..._uint32_update_crcs_with_value.out_with_nullmap | 1 +
.../column_uint32_update_hashes_with_value.out | Bin 0 -> 1777 bytes
...int32_update_hashes_with_value.out_with_nullmap | 1 +
.../column_uint32_update_sip_hash_with_value.out | Bin 0 -> 59 bytes
.../column_uint32_update_xxHash_with_value.out | Bin 0 -> 58 bytes
...int32_update_xxHash_with_value.out_with_nullmap | 1 +
.../column_uint64_update_crc_with_value.out | Bin 0 -> 50 bytes
...n_uint64_update_crc_with_value.out_with_nullmap | 1 +
.../column_uint64_update_crcs_with_value.out | Bin 0 -> 871 bytes
..._uint64_update_crcs_with_value.out_with_nullmap | 1 +
.../column_uint64_update_hashes_with_value.out | Bin 0 -> 1615 bytes
...int64_update_hashes_with_value.out_with_nullmap | 1 +
.../column_uint64_update_sip_hash_with_value.out | Bin 0 -> 61 bytes
.../column_uint64_update_xxHash_with_value.out | Bin 0 -> 61 bytes
...int64_update_xxHash_with_value.out_with_nullmap | 1 +
.../columns/column_uint8_update_crc_with_value.out | Bin 0 -> 49 bytes
...mn_uint8_update_crc_with_value.out_with_nullmap | 1 +
.../column_uint8_update_crcs_with_value.out | Bin 0 -> 72 bytes
...n_uint8_update_crcs_with_value.out_with_nullmap | 1 +
.../column_uint8_update_hashes_with_value.out | Bin 0 -> 112 bytes
...uint8_update_hashes_with_value.out_with_nullmap | 1 +
.../column_uint8_update_sip_hash_with_value.out | Bin 0 -> 58 bytes
.../column_uint8_update_xxHash_with_value.out | Bin 0 -> 59 bytes
...uint8_update_xxHash_with_value.out_with_nullmap | 1 +
.../vec/data_types/decimalv3_18_0_get_field.out | Bin 0 -> 1588 bytes
.../vec/data_types/decimalv3_18_18_get_field.out | Bin 0 -> 4336 bytes
.../vec/data_types/decimalv3_18_9_get_field.out | Bin 0 -> 22446 bytes
.../vec/data_types/decimalv3_1_0_get_field.out | Bin 0 -> 140 bytes
.../vec/data_types/decimalv3_1_1_get_field.out | Bin 0 -> 254 bytes
.../vec/data_types/decimalv3_27_9_get_field.out | Bin 0 -> 29142 bytes
.../vec/data_types/decimalv3_38_0_get_field.out | Bin 0 -> 3068 bytes
.../vec/data_types/decimalv3_38_30_get_field.out | Bin 0 -> 50910 bytes
.../vec/data_types/decimalv3_38_38_get_field.out | Bin 0 -> 8376 bytes
.../vec/data_types/decimalv3_76_0_get_field.out | Bin 0 -> 4683 bytes
.../vec/data_types/decimalv3_76_38_get_field.out | Bin 0 -> 31452 bytes
.../vec/data_types/decimalv3_76_76_get_field.out | Bin 0 -> 9374 bytes
.../vec/data_types/decimalv3_8_3_get_field.out | Bin 0 -> 54 bytes
.../vec/data_types/decimalv3_9_0_get_field.out | Bin 0 -> 713 bytes
.../vec/data_types/decimalv3_9_9_get_field.out | Bin 0 -> 649 bytes
.../vec/data_types/timev2_0_to_string.out | Bin 0 -> 272 bytes
.../vec/data_types/timev2_0_to_string_2.out | Bin 0 -> 272 bytes
.../vec/data_types/timev2_0_to_string_3.out | Bin 0 -> 272 bytes
.../vec/data_types/timev2_0_to_string_batch.out | Bin 0 -> 272 bytes
.../vec/data_types/timev2_5_to_string.out | Bin 0 -> 440 bytes
.../vec/data_types/timev2_5_to_string_2.out | Bin 0 -> 440 bytes
.../vec/data_types/timev2_5_to_string_3.out | Bin 0 -> 440 bytes
.../vec/data_types/timev2_5_to_string_batch.out | Bin 0 -> 440 bytes
.../vec/data_types/timev2_6_to_string.out | Bin 0 -> 468 bytes
.../vec/data_types/timev2_6_to_string_2.out | Bin 0 -> 468 bytes
.../vec/data_types/timev2_6_to_string_3.out | Bin 0 -> 468 bytes
.../vec/data_types/timev2_6_to_string_batch.out | Bin 0 -> 468 bytes
.../vec/data_types/timev2_to_string.out | Bin 0 -> 468 bytes
.../vec/data_types/timev2_to_string_2.out | Bin 0 -> 468 bytes
.../vec/data_types/timev2_to_string_3.out | Bin 0 -> 468 bytes
.../vec/data_types/timev2_to_string_batch.out | Bin 0 -> 468 bytes
be/test/io/cache/block_file_cache_test.cpp | 2 +-
be/test/olap/date_bloom_filter_test.cpp | 11 +-
be/test/olap/delete_bitmap_calculator_test.cpp | 113 +-
be/test/olap/inverted_index_profile_test.cpp | 8 +-
be/test/olap/pb_convert_test.cpp | 443 ++++
...icu_anzlyzer_test.cpp => icu_analyzer_test.cpp} | 6 +-
.../analyzer/simple_analyzer_test.cpp | 147 ++
.../inverted_index_compound_reader_test.cpp | 575 +++++
be/test/olap/segment_footer_cache_test.cpp | 195 ++
be/test/olap/wal/wal_manager_test.cpp | 455 +++-
be/test/pipeline/local_exchanger_test.cpp | 311 ---
...istinct_streaming_aggregation_operator_test.cpp | 198 ++
.../operator/exchange_source_operator_test.cpp | 186 ++
.../local_merge_sort_source_operator_test.cpp | 161 ++
be/test/pipeline/operator/operator_helper.h | 18 +
.../partitioned_aggregation_sink_operator_test.cpp | 467 ++++
...artitioned_aggregation_source_operator_test.cpp | 470 ++++
.../partitioned_aggregation_test_helper.cpp | 238 ++
.../operator/partitioned_aggregation_test_helper.h | 155 ++
.../partitioned_hash_join_probe_operator_test.cpp | 32 +-
.../partitioned_hash_join_sink_operator_test.cpp | 8 -
.../operator/partitioned_hash_join_test_helper.cpp | 76 +-
.../operator/partitioned_hash_join_test_helper.h | 83 +-
be/test/pipeline/operator/repeat_operator_test.cpp | 341 +++
be/test/pipeline/operator/sort_operator_test.cpp | 273 +++
.../operator/spillable_operator_test_helper.cpp | 76 +
.../operator/spillable_operator_test_helper.h | 132 ++
be/test/pipeline/operator/union_operator_test.cpp | 296 +++
be/test/pipeline/thrift_builder.h | 4 -
.../workload_group/dummy_workload_group_test.cpp | 101 +
be/test/testutil/column_helper.h | 11 +
be/test/testutil/creators.h | 44 +-
be/test/testutil/mock/mock_descriptors.h | 2 +
be/test/testutil/mock/mock_literal_expr.cpp | 47 +
.../mock/{mock_slot_ref.h => mock_literal_expr.h} | 47 +-
be/test/testutil/mock/mock_slot_ref.cpp | 11 +
be/test/testutil/mock/mock_slot_ref.h | 2 +
.../test/testutil/mock/mock_sorter.h | 28 +-
be/test/testutil/run_all_tests.cpp | 10 +-
be/test/testutil/test_util.cpp | 135 ++
be/test/testutil/test_util.h | 13 +
be/test/util/load_util_test.cpp | 64 +
be/test/vec/columns/column_array_test.cpp | 2 +-
be/test/vec/columns/column_decimal_test.cpp | 620 ++++++
be/test/vec/columns/column_dictionary_test.cpp | 379 ++++
be/test/vec/columns/column_object_test.cpp | 257 +++
be/test/vec/columns/column_string_test.cpp | 977 +++++++-
be/test/vec/columns/column_vector_test.cpp | 497 +++++
be/test/vec/columns/common_column_test.h | 1322 ++++++++++-
be/test/vec/core/column_string_test.cpp | 105 -
.../vec/data_types/common_data_type_serder_test.h | 98 +-
be/test/vec/data_types/data_type_array_test.cpp | 43 +-
.../vec/data_types/data_type_datetime_v1_test.cpp | 536 +++++
be/test/vec/data_types/data_type_decimal_test.cpp | 783 +++++++
.../data_type_fixed_length_object_test.cpp | 5 +-
be/test/vec/data_types/data_type_ip_test.cpp | 2 +-
be/test/vec/data_types/data_type_map_test.cpp | 491 ++++
be/test/vec/data_types/data_type_number_test.cpp | 496 +++++
be/test/vec/data_types/data_type_string_test.cpp | 340 +++
be/test/vec/data_types/data_type_struct_test.cpp | 404 ++++
be/test/vec/data_types/data_type_time_v2_test.cpp | 902 ++++++++
.../serde/data_type_serde_arrow_test.cpp | 159 +-
.../serde/data_type_serde_bitmap_test.cpp | 26 +-
.../serde/data_type_serde_datetime_v1_test.cpp | 190 ++
.../serde/data_type_serde_datetime_v2_test.cpp | 222 ++
.../serde/data_type_serde_decimal_test.cpp | 290 +++
.../data_types/serde/data_type_serde_hll_test.cpp | 27 +-
.../serde/data_type_serde_number_test.cpp | 239 ++
.../serde/data_type_serde_string_test.cpp | 196 ++
.../format/paimon/paimon_schema_change_test.cpp | 136 ++
be/test/vec/exec/vwal_scanner_test.cpp | 380 ----
be/test/vec/function/function_string_test.cpp | 18 +
be/test/vec/function/function_time_test.cpp | 12 +
be/test/vec/runtime/vdatetime_value_test.cpp | 45 +
build.sh | 100 +-
cloud/src/meta-service/meta_service.cpp | 66 +-
cloud/src/meta-service/meta_service_job.cpp | 91 +-
cloud/src/recycler/s3_accessor.cpp | 21 +-
cloud/test/s3_rate_limiter_test.cpp | 55 +-
common/cpp/s3_rate_limiter.cpp | 9 +-
common/cpp/s3_rate_limiter.h | 12 +-
docker/runtime/doris-compose/cluster.py | 324 ++-
docker/runtime/doris-compose/command.py | 412 ++--
docker/runtime/doris-compose/database.py | 122 +-
docker/runtime/doris-compose/resource/common.sh | 20 +-
docker/runtime/doris-compose/resource/init_be.sh | 11 +-
.../runtime/doris-compose/resource/init_cloud.sh | 16 +-
docker/runtime/doris-compose/resource/init_fe.sh | 44 +-
docker/runtime/doris-compose/utils.py | 24 +
.../create_preinstalled_scripts/paimon/run02.sql | 159 ++
.../doris/common/jni/utils/JavaUdfArrayType.java | 62 +
.../doris/common/jni/utils/JavaUdfDataType.java | 92 +-
.../doris/common/jni/utils/JavaUdfMapType.java | 90 +
.../doris/common/jni/utils/JavaUdfStructType.java | 67 +
.../apache/doris/common/jni/utils/UdfUtils.java | 24 +-
.../java/org/apache/doris/udf/BaseExecutor.java | 3 +-
fe/check/checkstyle/suppressions.xml | 3 +
.../main/java/org/apache/doris/common/Config.java | 19 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 22 +-
fe/fe-core/src/main/cup/sql_parser.cup | 8 +-
.../main/java/org/apache/doris/alter/Alter.java | 126 +-
.../org/apache/doris/alter/CloudRollupJobV2.java | 2 +-
.../apache/doris/alter/CloudSchemaChangeJobV2.java | 1 -
.../doris/analysis/AlterColumnStatsStmt.java | 9 +-
.../doris/analysis/CreateDataSyncJobStmt.java | 3 +
.../org/apache/doris/analysis/CreateMTMVStmt.java | 4 +-
.../apache/doris/analysis/CreateTableLikeStmt.java | 17 +-
.../org/apache/doris/analysis/CreateTableStmt.java | 25 +-
.../apache/doris/analysis/InvertedIndexUtil.java | 8 +-
.../org/apache/doris/analysis/SchemaTableType.java | 4 +-
.../apache/doris/analysis/ShowColumnStatsStmt.java | 3 +-
.../org/apache/doris/analysis/ShowDataStmt.java | 18 +-
.../apache/doris/analysis/ShowQueryStatsStmt.java | 10 +-
.../apache/doris/analysis/ShowTableStatsStmt.java | 9 +-
.../org/apache/doris/backup/BackupHandler.java | 16 +-
.../java/org/apache/doris/backup/RestoreJob.java | 5 +-
.../org/apache/doris/binlog/BinlogConfigCache.java | 70 +-
.../org/apache/doris/binlog/BinlogLagInfo.java | 17 +-
.../org/apache/doris/binlog/BinlogManager.java | 28 +-
.../java/org/apache/doris/binlog/BinlogUtils.java | 27 +-
.../java/org/apache/doris/binlog/DBBinlog.java | 19 +-
.../org/apache/doris/catalog/AzureResource.java | 58 +-
.../doris/catalog/BuiltinScalarFunctions.java | 2 +
.../apache/doris/catalog/ColocateTableIndex.java | 17 +-
.../java/org/apache/doris/catalog/Database.java | 42 +-
.../java/org/apache/doris/catalog/DatabaseIf.java | 29 +-
.../main/java/org/apache/doris/catalog/Env.java | 121 +-
.../org/apache/doris/catalog/FESessionMgr.java | 136 ++
.../org/apache/doris/catalog/FunctionRegistry.java | 14 +-
.../org/apache/doris/catalog/FunctionUtil.java | 5 -
.../main/java/org/apache/doris/catalog/MTMV.java | 4 -
.../org/apache/doris/catalog/MetadataViewer.java | 21 +-
.../java/org/apache/doris/catalog/OlapTable.java | 24 +-
.../org/apache/doris/catalog/OlapTableFactory.java | 14 +-
.../java/org/apache/doris/catalog/Replica.java | 18 +
.../java/org/apache/doris/catalog/S3Resource.java | 84 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 24 +
.../main/java/org/apache/doris/catalog/Table.java | 16 +
.../java/org/apache/doris/catalog/TableIf.java | 4 +
.../apache/doris/catalog/TemporaryTableMgr.java | 78 +
.../org/apache/doris/clone/DiskRebalancer.java | 8 +-
.../doris/clone/DynamicPartitionScheduler.java | 14 +
.../apache/doris/clone/PartitionRebalancer.java | 5 +-
.../org/apache/doris/clone/TabletSchedCtx.java | 42 +-
.../org/apache/doris/clone/TabletScheduler.java | 30 +-
.../apache/doris/cloud/catalog/CloudReplica.java | 4 +-
.../cloud/datasource/CloudInternalCatalog.java | 4 +-
.../transaction/CloudGlobalTransactionMgr.java | 17 +-
.../java/org/apache/doris/common/FeNameFormat.java | 7 +
.../doris/common/cache/NereidsSqlCacheManager.java | 19 +
.../apache/doris/common/proc/ReplicasProcNode.java | 5 +-
.../apache/doris/common/proc/TabletsProcDir.java | 7 +-
.../org/apache/doris/common/util/TimeUtils.java | 12 +
.../java/org/apache/doris/common/util/Util.java | 48 +
.../apache/doris/datasource/ExternalDatabase.java | 5 +
.../doris/datasource/FederationBackendPolicy.java | 54 +-
.../apache/doris/datasource/InternalCatalog.java | 54 +-
.../doris/datasource/hive/HiveMetadataOps.java | 10 +
.../apache/doris/datasource/hudi/HudiUtils.java | 8 +-
.../datasource/iceberg/IcebergMetadataOps.java | 16 +-
.../datasource/paimon/PaimonExternalTable.java | 2 +-
.../datasource/paimon/PaimonSchemaCacheValue.java | 12 +-
.../datasource/paimon/source/PaimonScanNode.java | 18 +-
.../datasource/paimon/source/PaimonSplit.java | 9 +
.../org/apache/doris/fs/obj/AzureObjStorage.java | 47 +-
.../java/org/apache/doris/fs/obj/ObjStorage.java | 4 +
.../java/org/apache/doris/fs/obj/S3ObjStorage.java | 88 +
.../doris/httpv2/controller/SessionController.java | 3 +-
.../org/apache/doris/httpv2/meta/MetaService.java | 13 +-
.../org/apache/doris/httpv2/rest/LoadAction.java | 21 +-
.../java/org/apache/doris/load/DeleteHandler.java | 15 +-
.../main/java/org/apache/doris/load/DeleteJob.java | 4 +-
.../org/apache/doris/load/StreamLoadHandler.java | 3 +
.../apache/doris/load/loadv2/BrokerLoadJob.java | 42 +-
.../apache/doris/load/loadv2/IngestionLoadJob.java | 2 +-
.../org/apache/doris/load/loadv2/SparkLoadJob.java | 2 +-
.../doris/load/routineload/KafkaProgress.java | 3 +
.../load/routineload/KafkaRoutineLoadJob.java | 26 +-
.../doris/load/routineload/RoutineLoadJob.java | 117 +-
.../doris/load/routineload/RoutineLoadManager.java | 46 +-
.../load/routineload/RoutineLoadProgress.java | 2 +-
.../load/routineload/RoutineLoadStatistic.java | 1 +
.../java/org/apache/doris/metric/MetricRepo.java | 110 +-
.../org/apache/doris/mtmv/MTMVPartitionUtil.java | 6 +
.../java/org/apache/doris/mysql/MysqlProto.java | 2 +-
.../org/apache/doris/mysql/privilege/Auth.java | 6 +-
.../apache/doris/mysql/privilege/UserProperty.java | 2 +-
.../doris/mysql/privilege/UserPropertyMgr.java | 11 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 20 +-
.../org/apache/doris/nereids/StatementContext.java | 2 +-
.../glue/translator/PhysicalPlanTranslator.java | 15 +
.../doris/nereids/jobs/executor/Rewriter.java | 4 +-
.../apache/doris/nereids/memo/StructInfoMap.java | 9 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 108 +-
.../parser/LogicalPlanBuilderForEncryption.java | 8 +-
.../org/apache/doris/nereids/rules/RuleType.java | 4 +-
.../doris/nereids/rules/analysis/BindRelation.java | 8 +-
.../mv/AbstractMaterializedViewRule.java | 11 +
.../exploration/mv/MaterializedViewUtils.java | 5 +-
.../expression/rules/FoldConstantRuleOnFE.java | 19 +-
.../LogicalOlapScanToPhysicalOlapScan.java | 3 +-
.../LogicalWindowToPhysicalWindow.java | 2 +-
.../rules/rewrite/MaxMinFilterPushDown.java | 2 +-
.../rules/rewrite/OperativeColumnDerive.java | 146 ++
.../doris/nereids/stats/ExpressionEstimation.java | 21 +-
.../doris/nereids/stats/FilterEstimation.java | 12 +-
.../trees/copier/LogicalPlanDeepCopier.java | 8 +-
.../executable/DateTimeExtractAndTransform.java | 28 +-
.../functions/executable/StringArithmetic.java | 47 +-
.../expressions/functions/scalar/YearOfWeek.java | 84 +
.../trees/expressions/literal/DateLiteral.java | 11 +-
.../trees/expressions/literal/DateTimeLiteral.java | 2 +-
.../expressions/visitor/ScalarFunctionVisitor.java | 5 +
.../apache/doris/nereids/trees/plans/PlanType.java | 8 +-
.../trees/plans/algebra/CatalogRelation.java | 15 +
.../plans/commands/AlterColumnStatsCommand.java} | 129 +-
.../trees/plans/commands/AlterSystemCommand.java | 2 +-
.../trees/plans/commands/AlterTableCommand.java | 3 +
.../plans/commands/AlterTableStatsCommand.java | 160 ++
.../commands/CreateMaterializedViewCommand.java | 5 +-
.../trees/plans/commands/ExecuteCommand.java | 12 +-
.../trees/plans/commands/ExportCommand.java | 12 +-
.../trees/plans/commands/PrepareCommand.java | 2 +-
.../trees/plans/commands/ShowAnalyzeCommand.java | 14 +-
.../trees/plans/commands/ShowBackupCommand.java | 190 ++
.../plans/commands/ShowCreateTableCommand.java | 3 +-
.../trees/plans/commands/ShowDataCommand.java | 16 +-
.../commands/ShowDynamicPartitionCommand.java | 7 +
.../plans/commands/ShowIndexStatsCommand.java | 142 ++
.../plans/commands/ShowPartitionIdCommand.java | 17 +-
.../plans/commands/ShowProcessListCommand.java | 3 +-
.../trees/plans/commands/ShowTableCommand.java | 20 +-
.../trees/plans/commands/ShowTableIdCommand.java | 10 +-
.../plans/commands/ShowTableStatusCommand.java | 63 +-
.../trees/plans/commands/ShowTabletIdCommand.java | 205 ++
.../trees/plans/commands/info/AddBackendOp.java | 7 -
.../trees/plans/commands/info/AddBrokerOp.java | 9 -
.../trees/plans/commands/info/AddFollowerOp.java | 7 -
.../trees/plans/commands/info/AddObserverOp.java | 7 -
.../plans/commands/info/AlterLoadErrorUrlOp.java | 7 -
.../trees/plans/commands/info/AlterSystemOp.java | 3 -
.../trees/plans/commands/info/CreateMTMVInfo.java | 10 +-
.../trees/plans/commands/info/CreateTableInfo.java | 32 +-
.../plans/commands/info/CreateTableLikeInfo.java | 11 +-
.../plans/commands/info/DecommissionBackendOp.java | 8 -
.../trees/plans/commands/info/DropAllBrokerOp.java | 9 -
.../trees/plans/commands/info/DropBackendOp.java | 8 -
.../trees/plans/commands/info/DropBrokerOp.java | 9 -
.../trees/plans/commands/info/DropFollowerOp.java | 7 -
.../trees/plans/commands/info/DropObserverOp.java | 7 -
.../trees/plans/commands/info/ModifyBackendOp.java | 8 -
.../info/ModifyFrontendOrBackendHostNameOp.java | 14 -
.../insert/OlapGroupCommitInsertExecutor.java | 15 +-
.../plans/logical/LogicalCatalogRelation.java | 15 +-
.../trees/plans/logical/LogicalEmptyRelation.java | 12 +-
.../trees/plans/logical/LogicalOlapScan.java | 134 +-
.../trees/plans/logical/LogicalOneRowRelation.java | 4 +
.../trees/plans/physical/PhysicalOlapScan.java | 38 +-
.../trees/plans/visitor/CommandVisitor.java | 25 +
.../apache/doris/nereids/types/DateTimeV2Type.java | 10 +-
.../org/apache/doris/nereids/util/DateUtils.java | 14 +-
.../apache/doris/nereids/util/RelationUtil.java | 2 +-
.../doris/nereids/util/TypeCoercionUtils.java | 2 +-
.../apache/doris/planner/GroupCommitPlanner.java | 2 +
.../org/apache/doris/planner/OlapScanNode.java | 23 +-
.../java/org/apache/doris/planner/SortNode.java | 20 +
.../plsql/functions/DorisFunctionRegistry.java | 5 +-
.../apache/doris/plugin/audit/AuditLogBuilder.java | 29 +-
.../java/org/apache/doris/policy/PolicyMgr.java | 3 +-
.../java/org/apache/doris/qe/ConnectContext.java | 167 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 43 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 6 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 4 +-
.../java/org/apache/doris/qe/MasterOpExecutor.java | 8 +
.../org/apache/doris/qe/MysqlConnectProcessor.java | 28 +-
.../java/org/apache/doris/qe/SessionVariable.java | 29 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 56 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 21 +-
.../computegroup/AllBackendComputeGroup.java | 63 +
.../computegroup/CloudComputeGroup.java} | 21 +-
.../doris/resource/computegroup/ComputeGroup.java | 102 +
.../resource/computegroup/ComputeGroupMgr.java | 59 +
.../resource/computegroup/MergedComputeGroup.java | 66 +
.../apache/doris/service/FrontendServiceImpl.java | 112 +-
.../apache/doris/statistics/AnalysisManager.java | 18 +-
.../apache/doris/statistics/OlapAnalysisTask.java | 89 +-
.../doris/statistics/StatisticsRepository.java | 95 +
.../doris/statistics/util/StatisticsUtil.java | 18 +
.../org/apache/doris/system/BeSelectionPolicy.java | 3 +-
.../org/apache/doris/system/SystemInfoService.java | 34 +-
.../ExternalFileTableValuedFunction.java | 1 +
.../doris/tablefunction/MetadataGenerator.java | 33 +-
.../doris/transaction/DatabaseTransactionMgr.java | 5 +-
.../doris/transaction/GlobalTransactionMgr.java | 31 +-
.../transaction/GlobalTransactionMgrIface.java | 9 +-
.../hudi/common/util/collection/DiskMap.java | 169 ++
.../java/org/apache/doris/alter/AlterTest.java | 57 +-
.../doris/analysis/AdminSetConfigStmtTest.java | 7 +
.../apache/doris/analysis/GroupByClauseTest.java | 3 +
.../java/org/apache/doris/analysis/StageTest.java | 10 +
.../apache/doris/analysis/VirtualSlotRefTest.java | 9 +
.../org/apache/doris/catalog/AdminStmtTest.java | 34 +
.../apache/doris/catalog/AzureResourceTest.java | 57 +
.../org/apache/doris/catalog/CreateTableTest.java | 96 +-
.../org/apache/doris/catalog/OlapTableTest.java | 10 +-
.../org/apache/doris/catalog/S3ResourceTest.java | 35 +
.../doris/clone/DecreaseReplicationNumTest.java | 166 ++
.../transaction/CloudGlobalTransactionMgrTest.java | 10 +-
.../doris/common/proc/IndexesProcNodeTest.java | 4 +-
.../org/apache/doris/common/util/UtilTest.java | 86 +
.../doris/datasource/hive/HiveMetadataOpsTest.java | 2 +-
.../doris/datasource/hudi/HudiUtilsTest.java | 97 +
.../org/apache/doris/load/DeleteHandlerTest.java | 3 +-
.../apache/doris/load/loadv2/SparkLoadJobTest.java | 3 +-
.../org/apache/doris/mysql/MysqlProtoTest.java | 2 +
.../translator/PhysicalPlanTranslatorTest.java | 3 +-
.../doris/nereids/jobs/RewriteTopDownJobTest.java | 3 +-
.../doris/nereids/memo/StructInfoMapTest.java | 15 +-
.../postprocess/MergeProjectPostProcessTest.java | 2 +-
.../PushDownFilterThroughProjectTest.java | 4 +-
.../properties/ChildOutputPropertyDeriverTest.java | 3 +
.../rules/SimplifyComparisonPredicateSqlTest.java | 25 +-
.../rules/rewrite/OperativeColumnDeriveTest.java | 90 +
.../doris/nereids/trees/expressions/UdfTest.java | 4 +
.../trees/expressions/literal/DateLiteralTest.java | 7 +-
.../doris/nereids/trees/plans/PlanEqualsTest.java | 9 +-
.../nereids/trees/plans/PlanToStringTest.java | 2 +-
.../plans/commands/AlterSystemCommandTest.java | 191 ++
.../plans/commands/ShowBackupCommandTest.java | 115 +
.../plans/commands/ShowIndexStatsCommandTest.java | 113 +
.../apache/doris/nereids/util/PlanConstructor.java | 2 +-
.../doris/planner/FederationBackendPolicyTest.java | 43 +
.../apache/doris/planner/ResourceTagQueryTest.java | 31 +-
.../doris/plugin/audit/AuditLogBuilderTest.java | 48 +
.../org/apache/doris/qe/ConnectContextTest.java | 3 +-
.../apache/doris/resource/ComputeGroupTest.java | 636 ++++++
.../doris/statistics/OlapAnalysisTaskTest.java | 235 +-
.../transaction/DatabaseTransactionMgrTest.java | 9 +-
.../transaction/GlobalTransactionMgrTest.java | 61 +-
.../java/org/apache/doris/utframe/MockUsers.java | 56 +
gensrc/proto/cloud.proto | 4 +
gensrc/proto/olap_file.proto | 17 +-
gensrc/thrift/Descriptors.thrift | 3 +-
gensrc/thrift/FrontendService.thrift | 63 +-
gensrc/thrift/PaloInternalService.thrift | 2 +-
gensrc/thrift/PlanNodes.thrift | 3 +
.../test_insert_table_with_dump_nereids_memo.out} | Bin 107 -> 126 bytes
.../data/correctness/test_str_to_date.out | Bin 729 -> 757 bytes
.../data/correctness_p0/test_time_round.out | Bin 1677 -> 5047 bytes
.../hive/ddl/test_hive_drop_db.out | Bin 0 -> 317 bytes
.../iceberg/test_iceberg_drop_db.out} | Bin 186 -> 194 bytes
.../info_schema_db/test_info_schema_db.out | Bin 6062 -> 6230 bytes
.../test_information_schema_timezone.out | Bin 0 -> 415 bytes
.../paimon/test_paimon_schema_change.out | Bin 0 -> 4601 bytes
.../cloud/test_cloud_mow_new_tablet_compaction.out | Bin 0 -> 206 bytes
.../test_cloud_mow_txn_insert_publish_conflict.out | Bin 0 -> 203 bytes
.../test_cloud_publish_skip_calc_cache_miss.out} | Bin 107 -> 183 bytes
.../test_array_map.out} | Bin
.../insert_group_commit_with_large_data.out | Bin 221 -> 383 bytes
.../test_basic_analyzer.out} | Bin 371 -> 245 bytes
.../{ => analyzer}/test_icu_analyzer.out | Bin
.../downgrade => load_p0/stream_load}/test1.json | 0
.../stream_load/test_group_commit_stream_load.out | Bin 276 -> 548 bytes
.../load_p0/stream_load/test_json_compress.out | Bin 0 -> 25202 bytes
.../testSelectMVWithTableAlias.out | Bin 186 -> 220 bytes
.../array/test_array_map_datetime_decimal.csv | 4 +-
.../array/test_array_map_largeInt_string.csv | 5 +-
.../map/test_map_array_bigint.csv | 1 +
.../map/test_map_array_date.csv | 1 +
.../map/test_map_array_datetime.csv | 1 +
.../map/test_map_array_datetimev2_5.csv | 1 +
.../map/test_map_array_decimalv3_1_0.csv | 1 +
.../map/test_map_array_decimalv3_27_9.csv | 1 +
.../map/test_map_array_decimalv3_38_30.csv | 1 +
.../map/test_map_array_decimalv3_76_56.csv | 1 +
.../map/test_map_array_double.csv | 1 +
.../map/test_map_array_float.csv | 1 +
.../nereids_function_p0/map/test_map_array_int.csv | 1 +
.../map/test_map_array_ipv4.csv | 1 +
.../map/test_map_array_ipv6.csv | 1 +
.../map/test_map_array_largeint.csv | 1 +
.../map/test_map_array_smallint.csv | 1 +
.../map/test_map_array_tinyint.csv | 1 +
.../map/test_map_array_varchar_65535.csv | 1 +
.../nereids_function_p0/map/test_map_bigint.csv | 1 +
.../data/nereids_function_p0/map/test_map_date.csv | 1 +
.../nereids_function_p0/map/test_map_datetime.csv | 1 +
.../map/test_map_datetimev2_6.csv | 1 +
.../map/test_map_decimalv3_16_10.csv | 1 +
.../map/test_map_decimalv3_38_30.csv | 1 +
.../map/test_map_decimalv3_76_56.csv | 1 +
.../map/test_map_decimalv3_7_4.csv | 1 +
.../nereids_function_p0/map/test_map_double.csv | 1 +
.../nereids_function_p0/map/test_map_float.csv | 1 +
.../data/nereids_function_p0/map/test_map_int.csv | 1 +
.../data/nereids_function_p0/map/test_map_ipv4.csv | 1 +
.../data/nereids_function_p0/map/test_map_ipv6.csv | 1 +
.../nereids_function_p0/map/test_map_largeint.csv | 1 +
.../map/test_map_map_char_double.csv | 1 +
.../map/test_map_map_datetime_decimal.csv | 1 +
.../map/test_map_map_ipv4_ipv6.csv | 1 +
.../map/test_map_map_largeInt_string.csv | 1 +
.../nereids_function_p0/map/test_map_smallint.csv | 1 +
.../nereids_function_p0/map/test_map_struct.csv | 1 +
.../nereids_function_p0/map/test_map_tinyint.csv | 1 +
.../map/test_map_varchar_65535.csv | 1 +
.../struct/test_struct_array_bigint.csv | 1 +
.../struct/test_struct_array_date.csv | 1 +
.../struct/test_struct_array_datetime.csv | 1 +
.../struct/test_struct_array_datetimev2_5.csv | 1 +
.../struct/test_struct_array_decimalv3_1_0.csv | 1 +
.../struct/test_struct_array_decimalv3_27_9.csv | 1 +
.../struct/test_struct_array_decimalv3_38_30.csv | 1 +
.../struct/test_struct_array_decimalv3_76_56.csv | 1 +
.../struct/test_struct_array_double.csv | 1 +
.../struct/test_struct_array_float.csv | 1 +
.../struct/test_struct_array_int.csv | 1 +
.../struct/test_struct_array_ipv4.csv | 1 +
.../struct/test_struct_array_ipv6.csv | 1 +
.../struct/test_struct_array_largeint.csv | 1 +
.../struct/test_struct_array_smallint.csv | 1 +
.../struct/test_struct_array_tinyint.csv | 1 +
.../struct/test_struct_array_varchar_65535.csv | 1 +
.../struct/test_struct_bigint.csv | 1 +
.../struct/test_struct_date.csv | 1 +
.../struct/test_struct_datetime.csv | 1 +
.../struct/test_struct_datetimev2_6.csv | 1 +
.../struct/test_struct_decimalv3_16_10.csv | 1 +
.../struct/test_struct_decimalv3_38_30.csv | 1 +
.../struct/test_struct_decimalv3_76_56.csv | 1 +
.../struct/test_struct_decimalv3_7_4.csv | 1 +
.../struct/test_struct_double.csv | 1 +
.../struct/test_struct_float.csv | 1 +
.../nereids_function_p0/struct/test_struct_int.csv | 1 +
.../struct/test_struct_ipv4.csv | 1 +
.../struct/test_struct_ipv6.csv | 1 +
.../struct/test_struct_largeint.csv | 1 +
.../struct/test_struct_map_char_double.csv | 1 +
.../struct/test_struct_map_datetime_decimal.csv | 1 +
.../struct/test_struct_map_ipv4_ipv6.csv | 1 +
.../struct/test_struct_map_largeInt_string.csv | 1 +
.../struct/test_struct_smallint.csv | 1 +
.../struct/test_struct_struct.csv | 1 +
.../struct/test_struct_tinyint.csv | 1 +
.../struct/test_struct_varchar_65535.csv | 1 +
.../data/nereids_syntax_p0/test_cast_datetime.out | Bin 107 -> 258 bytes
.../datetime_functions/test_date_function.out | Bin 10302 -> 10709 bytes
.../test_varchar_sc_in_complex.out | Bin 1429 -> 14064 bytes
.../data/temp_table_p0/temp_table_data.csv | 3 +
.../test_partial_update_complex_type.out | Bin 1855 -> 2735 bytes
.../doris/regression/action/TestAction.groovy | 2 +-
.../org/apache/doris/regression/suite/Suite.groovy | 2 +-
.../cloud_p0/conf/regression-conf-custom.groovy | 1 +
.../pipeline/external/conf/regression-conf.groovy | 1 -
.../vault_p0/conf/regression-conf-custom.groovy | 1 -
.../backup_restore/test_backup_restore.groovy | 20 +
.../test_backup_store_with_db_properties.groovy | 2 +-
.../test_backup_store_with_db_properties_kv.groovy | 2 +-
.../check_before_quit/check_before_quit.groovy | 11 +-
.../warm_up/hotspot/test_warmup_show_stmt_2.groovy | 2 +-
.../create_table_use_policy.groovy | 22 +
...test_insert_table_with_dump_nereids_memo.groovy | 58 +
.../suites/correctness/test_str_to_date.groovy | 5 +
.../suites/correctness_p0/test_time_round.groovy | 125 ++
.../ddl_p0/test_create_table_properties.groovy | 3 +-
regression-test/suites/ddl_p0/test_ctas.groovy | 2 +-
.../presto/scalar/timestamptz/TestOperators.sql | 1784 +++++++--------
.../hive/ddl/test_hive_ddl.groovy | 11 +
.../hive/ddl/test_hive_drop_db.groovy | 106 +
.../hive/test_hive_orc_predicate.groovy | 2 +-
.../iceberg/test_iceberg_drop_db.groovy | 112 +
.../info_schema_db/test_info_schema_db.groovy | 17 +
.../test_information_schema_timezone.groovy | 218 ++
.../paimon/test_paimon_schema_change.groovy | 88 +
.../test_cloud_mow_new_tablet_compaction.groovy | 143 ++
...st_cloud_mow_txn_insert_publish_conflict.groovy | 114 +
.../test_cloud_publish_skip_calc_cache_miss.groovy | 78 +
.../suites/function_p0/test_array_map.groovy | 232 ++
.../insert_group_commit_with_large_data.groovy | 54 +-
.../insert_group_commit_with_prepare_stmt.groovy | 5 +
.../test_basic_analyzer.groovy} | 6 +-
.../{ => analyzer}/test_icu_analyzer.groovy | 0
...t_metrics.csv => test_abnormal_job_monitor.csv} | 0
.../test_routin_load_abnormal_job_monitor.groovy | 225 ++
.../test_routine_load_job_info_system_table.groovy | 142 ++
.../test_group_commit_stream_load.groovy | 36 +
.../load_p0/stream_load/test_json_compress.groovy | 149 ++
.../load_p0/stream_load/test_stream_load.groovy | 2 +-
.../test_stream_load_with_filtered_rows.groovy | 94 +
.../test_dup_mv_useless/test_dup_mv_useless.groovy | 11 +-
.../mv_p0/unique_rewrite/unique_rewrite.groovy | 12 +-
.../testSelectMVWithTableAlias.groovy | 5 +-
.../cache/parse_sql_from_sql_cache.groovy | 7 +-
.../cache/prepare_stmt_with_sql_cache.groovy | 33 +-
.../ddl/clean/test_clean_label_nereids.groovy | 2 +-
.../fold_constant_date_arithmatic.groovy | 19 +
.../fold_constant_string_arithmatic.groovy | 158 +-
.../show/test_nereids_show_backup.groovy} | 29 +-
.../nereids_p0/stats/partitionRowCount.groovy | 2 +-
.../suites/nereids_p0/union/or_expansion.groovy | 54 +
.../mv/grouping_sets/grouping_sets.groovy | 2 +-
.../mv/join/dphyp_outer/outer_join_dphyp.groovy | 2 +-
.../mv/join/left_outer/outer_join.groovy | 6 +-
.../mv/same_name/sync_async_same_name.groovy | 2 +-
.../single_table_without_aggregate.groovy | 4 +-
.../mv/union_rewrite/usercase_union_rewrite.groovy | 13 +
.../mv/unsafe_equals/null_un_safe_equals.groovy | 2 +-
.../mv/with_auth/with_select_table_auth.groovy | 2 +-
.../mv/with_sql_limit/query_with_sql_limit.groovy | 2 +-
.../distribute/colocate_agg_join.groovy | 84 +
.../nereids_syntax_p0/test_cast_datetime.groovy | 538 ++++-
.../transform_outer_join_to_anti.groovy | 1 -
.../operative_slots/operative_slots.groovy | 79 +
.../datetime_functions/test_date_function.groovy | 24 +
.../suites/query_p0/test_forward_qeury.groovy | 7 +-
.../suites/query_profile/profile_level.groovy | 36 +-
.../test_varchar_sc_in_complex.groovy | 304 ++-
.../test_alter_table_set_column_stats.groovy | 55 +
.../suites/temp_table_p0/test_temp_table.groovy | 675 ++++++
.../test_temp_table_with_restart.groovy | 76 +
.../test_partial_update_complex_type.groovy | 35 +-
run-be-ut.sh | 14 +-
1012 files changed, 41438 insertions(+), 6366 deletions(-)
create mode 100644 be/src/cloud/cloud_compaction_stop_token.cpp
copy be/src/{runtime/memory/cache_policy.cpp =>
cloud/cloud_compaction_stop_token.h} (61%)
create mode 100644
be/src/exec/schema_scanner/schema_routine_load_job_scanner.cpp
copy be/src/exec/schema_scanner/{schema_backend_kerberos_ticket_cache.h =>
schema_routine_load_job_scanner.h} (72%)
create mode 100644 be/src/io/tools/CMakeLists.txt
copy {gensrc => be/src/io/tools}/Makefile (100%)
create mode 100644 be/src/io/tools/file_cache_microbench.cpp
create mode 100644 be/src/io/tools/proto/Makefile
copy
be/src/{olap/rowset/segment_v2/inverted_index/analyzer/icu/ICUTokenizerConfig.h
=> io/tools/proto/microbench.proto} (51%)
create mode 100644 be/src/io/tools/readme.md
copy be/src/olap/rowset/segment_v2/inverted_index/analyzer/{icu/ICUAnalyzer.h
=> basic/basic_analyzer.h} (66%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analyzer/basic/basic_tokenizer.cpp
copy be/src/olap/rowset/segment_v2/inverted_index/analyzer/{icu/ICUTokenizer.h
=> basic/basic_tokenizer.h} (70%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{BreakIteratorWrapper.cpp
=> break_iterator_wrapper.cpp} (96%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{BreakIteratorWrapper.h
=> break_iterator_wrapper.h} (96%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{CompositeBreakIterator.cpp
=> composite_break_iterator.cpp} (97%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{CompositeBreakIterator.h
=> composite_break_iterator.h} (91%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{DefaultICUTokenizerConfig.cpp
=> default_icu_tokenizer_config.cpp} (98%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{DefaultICUTokenizerConfig.h
=> default_icu_tokenizer_config.h} (95%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{ICUAnalyzer.h =>
icu_analyzer.h} (97%)
rename be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{ICUCommon.h
=> icu_common.h} (100%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{ICUTokenizer.cpp =>
icu_tokenizer.cpp} (97%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{ICUTokenizer.h =>
icu_tokenizer.h} (91%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{ICUTokenizerConfig.h
=> icu_tokenizer_config.h} (95%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{ScriptIterator.cpp
=> script_iterator.cpp} (98%)
rename
be/src/olap/rowset/segment_v2/inverted_index/analyzer/icu/{ScriptIterator.h =>
script_iterator.h} (97%)
create mode 100644 be/src/pipeline/exec/local_merge_sort_source_operator.cpp
create mode 100644 be/src/pipeline/exec/local_merge_sort_source_operator.h
create mode 100644 be/src/runtime/workload_group/dummy_workload_group.cpp
copy be/src/runtime/{workload_management/io_throttle.h =>
workload_group/dummy_workload_group.h} (52%)
create mode 100644 be/test/data/vec/columns/BIGINT.csv
create mode 100644 be/test/data/vec/columns/BIGINT_UNSIGNED.csv
create mode 100644 be/test/data/vec/columns/DATETIMEV1.csv
create mode 100644 be/test/data/vec/columns/DATETIMEV2(0).csv
create mode 100644 be/test/data/vec/columns/DATETIMEV2(5).csv
create mode 100644 be/test/data/vec/columns/DATETIMEV2(6).csv
create mode 100644 be/test/data/vec/columns/DATEV1.csv
create mode 100644 be/test/data/vec/columns/DATEV2.csv
create mode 100644 be/test/data/vec/columns/DECIMALV2(27,9).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(1,0).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(1,1).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(10,5).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(18,0).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(18,18).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(18,9).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(27,9).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(38,0).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(38,30).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(38,38).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(76,0).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(76,38).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(76,76).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(8,3).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(9,0).csv
create mode 100644 be/test/data/vec/columns/DECIMALV3(9,9).csv
create mode 100644 be/test/data/vec/columns/DICT_INDICES.csv
create mode 100644 be/test/data/vec/columns/DICT_STR.csv
create mode 100644 be/test/data/vec/columns/DOUBLE.csv
create mode 100644 be/test/data/vec/columns/FLOAT.csv
create mode 100644 be/test/data/vec/columns/INT.csv
create mode 100644 be/test/data/vec/columns/INT_UNSIGNED.csv
create mode 100644 be/test/data/vec/columns/LARGEINT.csv
create mode 100644 be/test/data/vec/columns/LARGEINT_UNSIGNED.csv
create mode 100644 be/test/data/vec/columns/SMALLINT.csv
create mode 100644 be/test/data/vec/columns/SMALLINT_UNSIGNED.csv
create mode 100644 be/test/data/vec/columns/STRING.csv
create mode 100644 be/test/data/vec/columns/TIMEV2(6).csv
create mode 100644 be/test/data/vec/columns/TINYINT.csv
create mode 100644 be/test/data/vec/columns/TINYINT_UNSIGNED.csv
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v1_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_date_v2_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v1_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_0_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_5_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_datetime_v2_6_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128_1_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal128v2_1_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128v2_1_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal128v2_1_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128v2_1_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal128v2_1_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128v2_1_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal128v2_1_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal256_1_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal32_1_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_decimal64_1_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_float32_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_float32_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_float32_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_float32_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_float32_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_float32_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_float32_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_float64_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_float64_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_float64_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_float64_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_float64_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_float64_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_float64_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int128_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int16_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int32_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int64_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_int8_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_ip_update_crc_hashes.out
create mode 100644
be/test/expected_result/vec/columns/column_ip_update_crc_hashes.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_ip_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_ip_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_ip_update_hashes_with_value1.out
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str32_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_str64_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint16_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint32_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint64_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_crc_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_crc_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_crcs_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_crcs_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_hashes_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_hashes_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_sip_hash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_xxHash_with_value.out
create mode 100644
be/test/expected_result/vec/columns/column_uint8_update_xxHash_with_value.out_with_nullmap
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_18_0_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_18_18_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_18_9_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_1_0_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_1_1_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_27_9_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_38_0_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_38_30_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_38_38_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_76_0_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_76_38_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_76_76_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_8_3_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_9_0_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/decimalv3_9_9_get_field.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_0_to_string.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_0_to_string_2.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_0_to_string_3.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_0_to_string_batch.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_5_to_string.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_5_to_string_2.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_5_to_string_3.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_5_to_string_batch.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_6_to_string.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_6_to_string_2.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_6_to_string_3.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_6_to_string_batch.out
create mode 100644 be/test/expected_result/vec/data_types/timev2_to_string.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_2.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_3.out
create mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_batch.out
create mode 100644 be/test/olap/pb_convert_test.cpp
rename
be/test/olap/rowset/segment_v2/inverted_index/analyzer/{icu_anzlyzer_test.cpp
=> icu_analyzer_test.cpp} (99%)
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/analyzer/simple_analyzer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index_compound_reader_test.cpp
create mode 100644 be/test/olap/segment_footer_cache_test.cpp
create mode 100644
be/test/pipeline/operator/distinct_streaming_aggregation_operator_test.cpp
create mode 100644 be/test/pipeline/operator/exchange_source_operator_test.cpp
create mode 100644
be/test/pipeline/operator/local_merge_sort_source_operator_test.cpp
create mode 100644
be/test/pipeline/operator/partitioned_aggregation_sink_operator_test.cpp
create mode 100644
be/test/pipeline/operator/partitioned_aggregation_source_operator_test.cpp
create mode 100644
be/test/pipeline/operator/partitioned_aggregation_test_helper.cpp
create mode 100644
be/test/pipeline/operator/partitioned_aggregation_test_helper.h
create mode 100644 be/test/pipeline/operator/repeat_operator_test.cpp
create mode 100644 be/test/pipeline/operator/sort_operator_test.cpp
create mode 100644 be/test/pipeline/operator/spillable_operator_test_helper.cpp
create mode 100644 be/test/pipeline/operator/spillable_operator_test_helper.h
create mode 100644 be/test/pipeline/operator/union_operator_test.cpp
create mode 100644 be/test/runtime/workload_group/dummy_workload_group_test.cpp
create mode 100644 be/test/testutil/mock/mock_literal_expr.cpp
copy be/test/testutil/mock/{mock_slot_ref.h => mock_literal_expr.h} (61%)
copy
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonSchemaCacheValue.java
=> be/test/testutil/mock/mock_sorter.h (61%)
create mode 100644 be/test/vec/columns/column_decimal_test.cpp
create mode 100644 be/test/vec/columns/column_dictionary_test.cpp
create mode 100644 be/test/vec/columns/column_object_test.cpp
create mode 100644 be/test/vec/columns/column_vector_test.cpp
delete mode 100644 be/test/vec/core/column_string_test.cpp
create mode 100644 be/test/vec/data_types/data_type_datetime_v1_test.cpp
create mode 100644 be/test/vec/data_types/data_type_decimal_test.cpp
create mode 100644 be/test/vec/data_types/data_type_map_test.cpp
create mode 100644 be/test/vec/data_types/data_type_number_test.cpp
create mode 100644 be/test/vec/data_types/data_type_string_test.cpp
create mode 100644 be/test/vec/data_types/data_type_struct_test.cpp
create mode 100644 be/test/vec/data_types/data_type_time_v2_test.cpp
create mode 100644
be/test/vec/data_types/serde/data_type_serde_datetime_v1_test.cpp
create mode 100644
be/test/vec/data_types/serde/data_type_serde_datetime_v2_test.cpp
create mode 100644
be/test/vec/data_types/serde/data_type_serde_decimal_test.cpp
create mode 100644 be/test/vec/data_types/serde/data_type_serde_number_test.cpp
create mode 100644 be/test/vec/data_types/serde/data_type_serde_string_test.cpp
create mode 100644 be/test/vec/exec/format/paimon/paimon_schema_change_test.cpp
delete mode 100644 be/test/vec/exec/vwal_scanner_test.cpp
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/paimon/run02.sql
create mode 100644
fe/be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils/JavaUdfArrayType.java
create mode 100644
fe/be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils/JavaUdfMapType.java
create mode 100644
fe/be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils/JavaUdfStructType.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/FESessionMgr.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/TemporaryTableMgr.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/OperativeColumnDerive.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/YearOfWeek.java
copy
fe/fe-core/src/main/java/org/apache/doris/{analysis/AlterColumnStatsStmt.java
=> nereids/trees/plans/commands/AlterColumnStatsCommand.java} (67%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AlterTableStatsCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowBackupCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowIndexStatsCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowTabletIdCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/computegroup/AllBackendComputeGroup.java
copy
fe/fe-core/src/main/java/org/apache/doris/{datasource/paimon/PaimonSchemaCacheValue.java
=> resource/computegroup/CloudComputeGroup.java} (62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/computegroup/ComputeGroup.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/computegroup/ComputeGroupMgr.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/computegroup/MergedComputeGroup.java
create mode 100644
fe/fe-core/src/main/java/org/apache/hudi/common/util/collection/DiskMap.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/AzureResourceTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/clone/DecreaseReplicationNumTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/util/UtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/OperativeColumnDeriveTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/AlterSystemCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/ShowBackupCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/ShowIndexStatsCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/plugin/audit/AuditLogBuilderTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/resource/ComputeGroupTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/utframe/MockUsers.java
copy regression-test/data/{nereids_syntax_p0/test_cast_datetime.out =>
correctness/test_insert_table_with_dump_nereids_memo.out} (76%)
create mode 100644
regression-test/data/external_table_p0/hive/ddl/test_hive_drop_db.out
copy
regression-test/data/{mv_p0/ut/testSelectMVWithTableAlias/testSelectMVWithTableAlias.out
=> external_table_p0/iceberg/test_iceberg_drop_db.out} (51%)
create mode 100644
regression-test/data/external_table_p0/info_schema_db/test_information_schema_timezone.out
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_schema_change.out
create mode 100644
regression-test/data/fault_injection_p0/cloud/test_cloud_mow_new_tablet_compaction.out
create mode 100644
regression-test/data/fault_injection_p0/cloud/test_cloud_mow_txn_insert_publish_conflict.out
copy regression-test/data/{nereids_syntax_p0/test_cast_datetime.out =>
fault_injection_p0/cloud/test_cloud_publish_skip_calc_cache_miss.out} (52%)
copy regression-test/data/{load_p0/stream_load/test_stream_load_empty_file.out
=> function_p0/test_array_map.out} (100%)
copy regression-test/data/inverted_index_p0/{test_icu_analyzer.out =>
analyzer/test_basic_analyzer.out} (66%)
rename regression-test/data/inverted_index_p0/{ =>
analyzer}/test_icu_analyzer.out (100%)
copy regression-test/data/{unique_with_mow_p0/flexible/downgrade =>
load_p0/stream_load}/test1.json (100%)
create mode 100644
regression-test/data/load_p0/stream_load/test_json_compress.out
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_bigint.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_date.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_datetime.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_datetimev2_5.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_decimalv3_1_0.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_decimalv3_27_9.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_decimalv3_38_30.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_decimalv3_76_56.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_double.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_float.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_int.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_ipv4.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_ipv6.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_largeint.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_smallint.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_tinyint.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_array_varchar_65535.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_bigint.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_date.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_datetime.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_datetimev2_6.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_decimalv3_16_10.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_decimalv3_38_30.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_decimalv3_76_56.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_decimalv3_7_4.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_double.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_float.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_int.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_ipv4.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_ipv6.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_largeint.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_map_char_double.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_map_datetime_decimal.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_map_ipv4_ipv6.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_map_largeInt_string.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_smallint.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_struct.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_tinyint.csv
create mode 100644
regression-test/data/nereids_function_p0/map/test_map_varchar_65535.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_bigint.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_date.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_datetime.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_datetimev2_5.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_decimalv3_1_0.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_decimalv3_27_9.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_decimalv3_38_30.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_decimalv3_76_56.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_double.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_float.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_int.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_ipv4.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_ipv6.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_largeint.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_smallint.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_tinyint.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_array_varchar_65535.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_bigint.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_date.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_datetime.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_datetimev2_6.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_decimalv3_16_10.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_decimalv3_38_30.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_decimalv3_76_56.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_decimalv3_7_4.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_double.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_float.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_int.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_ipv4.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_ipv6.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_largeint.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_map_char_double.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_map_datetime_decimal.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_map_ipv4_ipv6.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_map_largeInt_string.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_smallint.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_struct.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_tinyint.csv
create mode 100644
regression-test/data/nereids_function_p0/struct/test_struct_varchar_65535.csv
create mode 100644 regression-test/data/temp_table_p0/temp_table_data.csv
create mode 100644
regression-test/suites/correctness/test_insert_table_with_dump_nereids_memo.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/ddl/test_hive_drop_db.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_drop_db.groovy
create mode 100644
regression-test/suites/external_table_p0/info_schema_db/test_information_schema_timezone.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_schema_change.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_mow_new_tablet_compaction.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_mow_txn_insert_publish_conflict.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_publish_skip_calc_cache_miss.groovy
create mode 100644 regression-test/suites/function_p0/test_array_map.groovy
copy regression-test/suites/inverted_index_p0/{test_icu_analyzer.groovy =>
analyzer/test_basic_analyzer.groovy} (92%)
rename regression-test/suites/inverted_index_p0/{ =>
analyzer}/test_icu_analyzer.groovy (100%)
copy regression-test/suites/load_p0/routine_load/data/{test_metrics.csv =>
test_abnormal_job_monitor.csv} (100%)
create mode 100644
regression-test/suites/load_p0/routine_load/test_routin_load_abnormal_job_monitor.groovy
create mode 100644
regression-test/suites/load_p0/routine_load/test_routine_load_job_info_system_table.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_json_compress.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_with_filtered_rows.groovy
copy regression-test/suites/{backup_restore/test_backup_restore.groovy =>
nereids_p0/show/test_nereids_show_backup.groovy} (78%)
create mode 100644
regression-test/suites/nereids_syntax_p0/distribute/colocate_agg_join.groovy
create mode 100644
regression-test/suites/query_p0/operative_slots/operative_slots.groovy
copy
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonSchemaCacheValue.java
=> regression-test/suites/query_profile/profile_level.groovy (60%)
create mode 100644
regression-test/suites/statistics/test_alter_table_set_column_stats.groovy
create mode 100644 regression-test/suites/temp_table_p0/test_temp_table.groovy
create mode 100644
regression-test/suites/temp_table_p0/test_temp_table_with_restart.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
