This is an automated email from the ASF dual-hosted git repository.
englefly pushed a change to branch groupjoin
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 35fd87bf58c [fix](fe) Fix GroupJoin session variable annotation
discard 55806a79d39 fix be
discard 81b95bf74ba fe-part (#64763)
discard 70889d7b601 be fix
discard 8eb13c229e8 be part
discard 2b1c82e4d82 thrift
add ded08aebefd [fix](binlog) Commit table stream offsets for empty
inserts (#67126)
add 9a7174edb22 [refactor](catalog) Unify external metadata cache
framework (#66633)
add ad7e343bf20 [fix](cloud) Prevent FDB CloudUT ASAN getentropy crash
(#67316)
add ac948fe223e [fix](hdfs) Remove query profile from HDFS file reader
(#67335)
add fb0b0c5358e [refactor](parser) Dispatch parser statements by first
token (#66944)
add 2cf32a3bbdc [chore](thirdparty) upgrade thrift from 0.16.0 to 0.24.0
(#65990)
add 73ec045f5dc [feature](cloud) support single rowset grouped compaction
(#65907)
add df36be5a86d [fix](point query) Keep point-query scan when partition
pruning is empty (#67161)
add 824401b0514 [feature](agg_state) Add aggregate state combine
combinator (#66942)
add 61ada86cd90 [opt](bucket pruning) Avoid materializing tablet IDs
during pruning (#67150)
add a10c799e787 [Feature](lambda) Support some map lambda functions
(#66968)
add 7219c67265b [feat](cloud) Support Cloud partition inverted format
rollout (#66475)
add feb9e04f784 [bugfix](cancel) cancel message is printed too many times
(#67344)
add bd6673b756d [Enhancement](row binlog) Support flexible partial updates
(#66899)
add 11171329d6d [feature](inverted-index) Add Japanese (Kuromoji)
morphological analyzer (#64667)
add 0fb9b450865 [fix](view) Skip dangling views when querying
information_schema.view_dependency (#67339)
add 33e0c0b69f4 Revert "[fix](build) Keep Arrow 17 and 24 in shared
thirdparty" (#67330)
add 27e68bde457 [fix](cloud) Exclude stale rowsets from schema change
temporary tablet (#67351)
add 5ae9e79ad22 [feature](binlog) Keep row binlog tablets colocated with
base tablets (#66191)
add 5fbe3600024 [fix](zonemap) Treat unparsable zone map as invalid
(#67341)
add 952bfcbb40f [chore](lance) update some patch about lance (#67262)
add bd973648f43 [fix](fe) Use service-specific Ranger select access types
(#67206)
add 53a7c36a9e3 [fix](fe) Avoid redundant partition version fetch during
SQL cache validation (#67125)
add fc3235c3c95 [fix](be) Handle incomplete WAL records during replay
(#67204)
add e5a4e725fac [fix](cloud) Wait for running transactions before
incremental reads (#67181)
add 5c16fe4a1fc [chore](readme) Add UTM parameters to the Slack links so
GitHub clicks are attributed (#67430)
add 18894dd4a41 [fix](arm) fix compile error in arm platform (#67419)
add 2a3a3908809 [opt](build) Decouple common/status.h from thrift/protobuf
generated headers (#67036)
add 049410596f4 [feature](http) Add structured type metadata to table
schema API (#66670)
add ddbaaab1388 [fix](build) prevent math regression from global lance-c
linkage (#67237)
add da1eb726de9 [improvement](parser) Left factor primary expression
grammar (#66951)
add 1250443134f [fix](sqlcache) Do not replay the MySQL sql cache on an
Arrow Flight connection (#67381)
add 72071af801d [fix](fe) Return transaction insert execution errors
(#67386)
add b1d21a66ebd [fix](job) Prevent stale cloud broker load retries (#67250)
add f054492cbb9 [improvement](parser) Factor common EXPLAIN and CTE
prefixes (#67427)
add 224ba5f20b8 [improvement](parser) Factor LIMIT clause common prefix
(#67455)
add 383be27d963 [fix](build) Fix two arm64 BE build failures:
kuromoji_build_dict link and SNII_CRC32C_X86 -Wundef (#67451)
add 71a63249bbd [fix](be) Own the allocated LSN map in SharedMemtable to
fix UAF on flush task teardown (#67442)
add 7829cb730a3 [chore](paimon) remove paimon-cpp dependency (#67385)
add 38339c5d1c4 [improvement](auth) Scope mysql.user rows to the caller
and mask password columns (#67444)
add d34f06b5da2 [fix](be): fix BE access to aws under eks pod identity
(#67076)
add d145a5d4983 [improvement](parser) Skip hidden tokens in internal SQL
parsing (#67434)
add cdb05784a44 [improvement](parser) Localize identifier post-processing
(#67457)
add b4c6d132185 [fix](cloud) Avoid conflicts when recycling transactions
with the same label (#65746)
add fedf8740ca3 [fix](build) Allow Doris hidden columns in Gitleaks
(#67477)
add b42ebc83bfd [fix](parser) Remove stale post-processor usage from limit
test (#67482)
add 74d11cd21a8 [fix](ci) Migrate code review tracing to OTLP (#67413)
add b5148780cf7 [fix](ci) Accept a hyphen in the PR title, and stop
ignoring .github (#67491)
add 182022b593a [fix](file cache) keep the cache monitor off the LRU
recorder lock (#67315)
add 219c6193f24 [fix](iceberg) Preserve nested field case in created
schemas (#67166)
add 099d5bd71df [fix](arrow-flight) Do not take the point-query short
circuit on an Arrow Flight connection (#67487)
add a560c746fa9 [feature](ivm) Support incremental view maintenance (IVM)
for materialized tables (MTMV) (#62606)
add b502984a1cf [chore](build) Assign owners for workflows and thirdparty
(#67519)
add d326680d9ae [refactor](statistics) Organize statistics classes by
responsibility (#67483)
add 4eb013c29f7 [fix](paimon) tolerate removed paimon-cpp session variable
(#67472)
add 60854dbfb52 [feat](stream) Support ALTER STREAM ... SET/MODIFY COMMENT
(#67471)
add de9ed8ee903 [fix](udf) Reject variadic user-defined functions (#67373)
add 146d3595566 [improvement](parser) Assign query organization to a
single owner (#67429)
add 4ab2cd71095 [feature](function) Add array_except_all scalar function
(#67132)
add 91ffd58c03a thrift
add 8ba243d82cf be part
add 9856466f9ee be fix
add aa55aed793b fe-part (#64763)
add 1353543a175 fix be
add 762d4a2721f [fix](fe) Fix GroupJoin session variable annotation
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 (35fd87bf58c)
\
N -- N -- N refs/heads/groupjoin (762d4a2721f)
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:
.clang-format-ignore | 1 +
.github/CODEOWNERS | 2 +
.github/scripts/emit_litefuse_otel_io.py | 507 ++++-
.github/scripts/test_emit_litefuse_otel_io.py | 633 ++++++
.github/workflows/be-ut-mac.yml | 21 +-
.github/workflows/build-thirdparty.yml | 36 +-
.github/workflows/title-checker.yml | 8 +-
.gitignore | 4 +-
.gitleaks.toml | 6 +
.licenserc.yaml | 1 +
LICENSE.txt | 8 +
NOTICE.txt | 3 +
README.md | 6 +-
be/CMakeLists.txt | 171 +-
be/cmake/thirdparty.cmake | 58 +-
be/dict/kuromoji/README.md | 60 +
be/src/agent/be_exec_version_manager.h | 4 +
be/src/agent/cgroup_cpu_ctl.cpp | 1 +
be/src/agent/cgroup_cpu_ctl.h | 1 +
be/src/agent/task_worker_pool.cpp | 6 +-
be/src/cloud/cloud_backend_service.cpp | 1 +
be/src/cloud/cloud_cumulative_compaction.cpp | 205 +-
be/src/cloud/cloud_cumulative_compaction.h | 34 +
be/src/cloud/cloud_internal_service.cpp | 1 +
be/src/cloud/cloud_meta_mgr.cpp | 1 +
be/src/cloud/cloud_rowset_writer.cpp | 4 +
be/src/cloud/cloud_schema_change_job.cpp | 11 +-
be/src/cloud/cloud_snapshot_mgr.cpp | 2 +
be/src/cloud/cloud_storage_engine.cpp | 9 +-
be/src/cloud/cloud_tablet.cpp | 6 +
be/src/cloud/config.cpp | 3 +
be/src/cloud/config.h | 3 +
be/src/cloud/pb_convert.cpp | 4 +
be/src/common/config.cpp | 40 +-
be/src/common/config.h | 7 +-
be/src/common/exception.h | 1 -
be/src/common/status.cpp | 33 +
be/src/common/status.h | 129 +-
be/src/core/data_type/data_type.cpp | 8 +
be/src/core/data_type/data_type.h | 13 +-
be/src/core/data_type/data_type_array.cpp | 7 +
be/src/core/data_type/data_type_array.h | 6 +-
.../data_type/data_type_date_or_datetime_v2.cpp | 6 +
.../core/data_type/data_type_date_or_datetime_v2.h | 4 +-
be/src/core/data_type/data_type_decimal.cpp | 9 +
be/src/core/data_type/data_type_decimal.h | 5 +-
be/src/core/data_type/data_type_map.cpp | 10 +
be/src/core/data_type/data_type_map.h | 8 +-
be/src/core/data_type/data_type_string.cpp | 8 +
be/src/core/data_type/data_type_string.h | 6 +-
be/src/core/data_type/data_type_struct.cpp | 14 +
be/src/core/data_type/data_type_struct.h | 12 +-
be/src/core/data_type/data_type_timestamptz.cpp | 6 +
be/src/core/data_type/data_type_timestamptz.h | 4 +-
be/src/core/data_type/data_type_varbinary.cpp | 6 +
be/src/core/data_type/data_type_varbinary.h | 4 +-
be/src/core/data_type/data_type_variant.cpp | 8 +
be/src/core/data_type/data_type_variant.h | 6 +-
.../core/data_type_serde/data_type_array_serde.cpp | 1 +
.../core/data_type_serde/data_type_map_serde.cpp | 2 +
.../data_type_serde/data_type_nullable_serde.cpp | 9 +-
.../data_type_serde/data_type_struct_serde.cpp | 2 +
be/src/exec/common/endian.h | 29 +-
be/src/exec/pipeline/pipeline_fragment_context.cpp | 15 +-
be/src/exec/pipeline/pipeline_fragment_context.h | 10 +-
be/src/exec/pipeline/pipeline_task.cpp | 2 +-
be/src/exec/pipeline/task_scheduler.cpp | 10 +-
be/src/exec/scan/file_scanner.cpp | 52 +-
be/src/exec/scan/file_scanner_v2.cpp | 8 +-
be/src/exec/scan/split_source_connector.cpp | 2 +
be/src/exec/sink/vrow_distribution.cpp | 1 +
be/src/exec/sink/writer/vfile_result_writer.cpp | 2 +-
.../aggregate/aggregate_function_state_combine.h | 244 ++
.../function/array/function_array_except_all.cpp | 155 ++
.../function/array/function_array_register.cpp | 2 +
be/src/exprs/function/function_format.cpp | 1 +
be/src/exprs/function/function_map.cpp | 242 +-
be/src/exprs/function/function_tokenize.cpp | 2 +-
.../exprs/lambda_function/varray_map_function.cpp | 12 +-
be/src/exprs/vectorized_agg_fn.cpp | 94 +-
be/src/format/generic_reader.h | 2 +-
be/src/format/table/paimon_cpp_reader.cpp | 417 ----
be/src/format/table/paimon_cpp_reader.h | 101 -
be/src/format/table/paimon_doris_file_system.cpp | 679 ------
be/src/format/table/paimon_predicate_converter.cpp | 657 ------
be/src/format/table/paimon_predicate_converter.h | 88 -
be/src/glibc-compatibility/CMakeLists.txt | 18 +-
be/src/glibc-compatibility/lance_symbol_versions.c | 92 +
be/src/information_schema/schema_user_scanner.cpp | 3 +
be/src/io/cache/block_file_cache.cpp | 1 -
be/src/io/cache/lru_queue_recorder.cpp | 15 -
be/src/io/cache/lru_queue_recorder.h | 3 -
be/src/io/file_factory.cpp | 4 +-
be/src/io/fs/benchmark/hdfs_benchmark.hpp | 6 +-
be/src/io/fs/hdfs_file_reader.cpp | 78 +-
be/src/io/fs/hdfs_file_reader.h | 24 +-
be/src/io/fs/hdfs_file_system.cpp | 17 +-
be/src/io/fs/hdfs_file_system.h | 7 +-
be/src/load/group_commit/wal/wal_file_reader.cpp | 70 +-
be/src/load/group_commit/wal/wal_table.cpp | 3 +-
be/src/load/group_commit/wal/wal_writer.cpp | 13 +
be/src/load/memtable/memtable_flush_executor.cpp | 17 +-
be/src/load/memtable/memtable_flush_executor.h | 8 +-
be/src/runtime/aws_msk_iam_auth.cpp | 5 +-
be/src/runtime/fragment_mgr.cpp | 5 +-
be/src/runtime/query_context.cpp | 36 +-
be/src/runtime/query_context.h | 5 +-
be/src/runtime/snapshot_loader.cpp | 2 +-
.../workload_management/query_task_controller.cpp | 4 +-
.../workload_management/query_task_controller.h | 3 +-
be/src/service/backend_service.h | 1 +
be/src/service/doris_main.cpp | 2 +-
.../service/http/action/be_thread_stack_action.cpp | 2 +
.../http/action/show_nested_index_file_action.cpp | 5 +
be/src/service/http/http_handler_with_auth.cpp | 1 +
be/src/storage/binlog.h | 5 +
be/src/storage/compaction/compaction.cpp | 74 +-
be/src/storage/compaction/compaction.h | 32 +-
.../storage/index/inverted/analyzer/analyzer.cpp | 20 +-
.../inverted/analyzer/kuromoji/KuromojiAnalyzer.h | 75 +
.../inverted/analyzer/kuromoji/KuromojiMode.h | 48 +
.../analyzer/kuromoji/KuromojiTokenizer.cpp | 207 ++
.../inverted/analyzer/kuromoji/KuromojiTokenizer.h | 53 +
.../index/inverted/analyzer/kuromoji/dict/darts.h | 1979 ++++++++++++++++
.../analyzer/kuromoji/dict/kuromoji_dict_format.h | 129 ++
.../analyzer/kuromoji/dict/kuromoji_dictionary.cpp | 325 +++
.../analyzer/kuromoji/dict/kuromoji_dictionary.h | 140 ++
.../kuromoji/dict/kuromoji_dictionary_builder.cpp | 263 +++
.../kuromoji/dict/kuromoji_dictionary_builder.h | 75 +
.../kuromoji/dict/kuromoji_ipadic_parser.cpp | 301 +++
.../kuromoji/dict/kuromoji_ipadic_parser.h | 50 +
.../analyzer/kuromoji/kuromoji_normalize.h | 68 +
.../analyzer/kuromoji/kuromoji_viterbi.cpp | 301 +++
.../inverted/analyzer/kuromoji/kuromoji_viterbi.h | 64 +
.../index/inverted/inverted_index_parser.cpp | 17 +-
.../storage/index/inverted/inverted_index_parser.h | 7 +-
be/src/storage/index/inverted/setting.h | 1 +
be/src/storage/index/snii/encoding/crc32c.cpp | 5 +
be/src/storage/index/zone_map/zone_map_index.cpp | 14 +-
be/src/storage/iterator/vertical_block_reader.cpp | 70 +-
be/src/storage/iterator/vertical_block_reader.h | 9 +
be/src/storage/merger.cpp | 67 +-
be/src/storage/merger.h | 17 +-
be/src/storage/olap_server.cpp | 1 +
be/src/storage/partial_update_info.cpp | 110 +-
be/src/storage/partial_update_info.h | 24 +-
be/src/storage/rowid_conversion.h | 20 +-
be/src/storage/rowset/beta_rowset_writer.cpp | 4 +
be/src/storage/rowset/rowset_meta.cpp | 51 +-
be/src/storage/rowset/rowset_meta.h | 46 +-
be/src/storage/rowset/rowset_writer_context.h | 6 +-
.../storage/rowset/vertical_beta_rowset_writer.cpp | 6 +-
be/src/storage/rowset_builder.cpp | 58 +-
be/src/storage/rowset_builder.h | 2 +
be/src/storage/segment/column_reader.cpp | 39 +-
.../storage/segment/historical_row_retriever.cpp | 135 ++
be/src/storage/segment/historical_row_retriever.h | 8 +
be/src/storage/segment/segment.cpp | 49 +-
be/src/storage/tablet/tablet.cpp | 1 +
be/src/storage/tablet/tablet_meta.cpp | 25 +-
be/src/storage/tablet/tablet_meta.h | 15 +
be/src/storage/transform/row_binlog_derive.cpp | 48 +-
be/src/storage/transform/row_binlog_derive.h | 10 +-
be/src/storage/txn/txn_manager.cpp | 57 +-
be/src/storage/txn/txn_manager.h | 10 +-
be/src/tools/kuromoji_build_dict.cpp | 202 ++
be/src/util/hash_util.hpp | 35 +-
be/src/util/network_util.cpp | 8 +
be/src/util/thrift_util.cpp | 2 +-
be/src/util/timezone_utils.cpp | 1 +
be/src/util/uid_util.cpp | 16 +
be/test/CMakeLists.txt | 6 +
be/test/agent/heartbeat_server_test.cpp | 1 +
be/test/cloud/cloud_compaction_test.cpp | 369 ++-
.../cloud_cumulative_compaction_policy_test.cpp | 19 +
be/test/cloud/cloud_meta_mgr_test.cpp | 53 +
be/test/cloud/cloud_schema_change_job_test.cpp | 63 +-
be/test/cloud/cloud_snapshot_mgr_test.cpp | 7 +
be/test/common/status_test.cpp | 1 +
.../data_type_serde_fixed_length_object_test.cpp | 1 +
.../data_type_serde_number_test.cpp | 14 +
.../runtime_filter/sync_size_callback_test.cpp | 1 +
be/test/exec/scan/file_scanner_v2_test.cpp | 18 -
.../schema_tso_status_scanner_test.cpp | 1 +
be/test/exec/sink/vrow_distribution_test.cpp | 1 +
be/test/exprs/aggregate/agg_state_combine_test.cpp | 279 +++
.../function/function_array_except_all_test.cpp | 102 +
be/test/exprs/function/function_map_test.cpp | 257 +++
.../lambda_function/array_map_function_test.cpp | 54 +-
be/test/format/table/paimon_cpp_reader_test.cpp | 350 ---
.../format/table/paimon_doris_file_system_test.cpp | 59 -
be/test/format/wal/wal_reader_writer_test.cpp | 80 +
be/test/io/cache/cache_lru_dumper_test.cpp | 29 +-
.../cache/cached_remote_file_reader_peer_test.cpp | 1 +
.../io/fs/rate_limited_obj_storage_client_test.cpp | 1 +
be/test/io/fs/s3_file_writer_test.cpp | 1 +
be/test/io/s3_client_factory_test.cpp | 207 +-
.../load/memtable/memtable_flush_executor_test.cpp | 171 +-
be/test/runtime/aws_msk_iam_auth_test.cpp | 54 +
be/test/runtime/load_stream_test.cpp | 2 +
.../cloud_file_cache_write_index_only_test.cpp | 5 +
.../analyzer/kuromoji/darts_smoke_test.cpp | 70 +
.../kuromoji/kuromoji_dict_format_test.cpp | 48 +
.../kuromoji/kuromoji_dictionary_builder_test.cpp | 74 +
.../analyzer/kuromoji/kuromoji_dictionary_test.cpp | 155 ++
.../kuromoji/kuromoji_ipadic_parser_test.cpp | 109 +
.../analyzer/kuromoji/kuromoji_normalize_test.cpp | 50 +
.../analyzer/kuromoji/kuromoji_real_dict_test.cpp | 177 ++
.../analyzer/kuromoji/kuromoji_viterbi_test.cpp | 256 +++
.../inverted/analyzer/kuromoji_analyzer_test.cpp | 66 +
.../inverted/analyzer/kuromoji_tokenizer_test.cpp} | 27 +-
.../index/inverted/kuromoji_parser_type_test.cpp} | 30 +-
.../iterator/vertical_block_reader_test.cpp | 136 ++
be/test/storage/pb_convert_test.cpp | 24 +
be/test/storage/rowid_conversion_test.cpp | 390 +++-
be/test/storage/rowset/beta_rowset_test.cpp | 31 +
be/test/storage/rowset/rowset_meta_test.cpp | 102 +
.../storage/rowset/segment_flusher_format_test.cpp | 406 +++-
.../engine_storage_migration_task_test.cpp | 258 ++-
.../bloom_filter_index_reader_writer_test.cpp | 1 +
be/test/storage/segment/bloom_filter_test.cpp | 1 +
be/test/storage/segment/zone_map_index_test.cpp | 38 +
be/test/storage/tablet/tablet_meta_test.cpp | 50 +
.../storage/transform/row_binlog_derive_test.cpp | 50 +-
be/test/testutil/container_credentials_endpoint.h | 99 +
be/test/testutil/gperftools_stubs.cpp | 15 +-
.../testutil/mock/obj_storage_client_test_stub.h | 2 +
build-support/check-header-deps.py | 55 +-
build-support/compile-bench/syntax_sweep.py | 18 +-
build-support/tests/test-fe-connector-imports.sh | 4 +-
build.sh | 111 +-
cloud/src/recycler/recycler.cpp | 104 +-
cloud/test/CMakeLists.txt | 37 +
cloud/test/fdb_getentropy_compat.c | 113 +
cloud/test/recycler_test.cpp | 231 +-
cloud/test/s3_accessor_mock_test.cpp | 74 +
common/cpp/aws_common.cpp | 58 +
common/cpp/aws_common.h | 28 +
.../cpp/custom_aws_credentials_provider_chain.cpp | 50 +-
.../cpp/obj-client/auth/aws_credential_factory.cpp | 4 +-
common/cpp/test/container_credentials_test_util.h | 131 ++
dist/LICENSE-dist.txt | 2 +
dist/licenses/LICENSE-darts-clone.txt | 11 +
dist/licenses/LICENSE-ipadic.txt | 71 +
.../doris/analysis/InvertedIndexProperties.java | 21 +-
.../main/java/org/apache/doris/catalog/Column.java | 17 +
.../main/java/org/apache/doris/common/Config.java | 18 +
.../java/org/apache/doris/common/ConfigBase.java | 15 +
fe/fe-connector/fe-connector-adbc/pom.xml | 5 +-
.../apache/doris/connector/adbc/AdbcConnector.java | 5 +-
.../doris/connector/adbc/AdbcMetadataCache.java | 98 +-
fe/fe-connector/fe-connector-cache/pom.xml | 19 +-
.../apache/doris/connector/cache/CacheFactory.java | 127 --
.../apache/doris/connector/cache/CacheSpec.java | 11 +-
.../doris/connector/cache/CatalogMetaCache.java | 116 +
.../connector/cache/ConnectorMetadataCache.java | 38 +-
.../apache/doris/connector/cache/MetaCache.java | 152 ++
.../doris/connector/cache/MetaCacheDefinition.java | 153 ++
.../doris/connector/cache/MetaCacheEntry.java | 377 ----
.../doris/connector/cache/MetaCacheEntryStats.java | 201 --
.../connector/cache/MetaCacheRemovalListener.java} | 13 +-
.../connector/cache/MetaCacheRemovalReason.java} | 14 +-
.../apache/doris/connector/cache/ScopePath.java | 166 ++
.../doris/connector/cache/ScopedMetaCache.java | 1197 ++++++++++
.../connector/cache/ScopedMetaCacheRegistry.java | 958 ++++++++
.../doris/connector/cache/StripedPhaseGate.java | 111 +
.../doris/connector/cache/CacheSpecTest.java | 5 +-
.../connector/cache/CatalogMetaCacheTest.java | 312 +++
.../doris/connector/cache/MetaCacheEntryTest.java | 298 ---
.../doris/connector/cache/ScopePathTest.java | 77 +
.../cache/ScopedMetaCacheConcurrencyTest.java | 1405 ++++++++++++
.../cache/ScopedMetaCacheHierarchyTest.java | 371 +++
.../connector/cache/ScopedMetaCacheLeakTest.java | 335 +++
.../connector/cache/StripedPhaseGateTest.java | 160 ++
fe/fe-connector/fe-connector-hive/pom.xml | 11 +-
.../apache/doris/connector/hive/HiveConnector.java | 75 +-
.../hive/HiveDirectoryListingException.java | 2 +-
.../doris/connector/hive/HiveFileListingCache.java | 55 +-
.../hive/HiveConnectorInvalidateTest.java | 11 +-
.../connector/hive/HiveFileListingCacheTest.java | 2 +-
fe/fe-connector/fe-connector-hms/pom.xml | 9 +-
.../doris/connector/hms/CachingHmsClient.java | 144 +-
.../doris/connector/hms/CachingHmsClientTest.java | 127 +-
.../apache/doris/connector/hudi/HudiConnector.java | 41 +-
.../connector/hudi/HudiConnectorHmsCacheTest.java | 15 +-
fe/fe-connector/fe-connector-iceberg/pom.xml | 7 +-
.../doris/connector/iceberg/IcebergCatalogOps.java | 17 +-
.../connector/iceberg/IcebergCommentCache.java | 41 +-
.../connector/iceberg/IcebergComplexTypeDiff.java | 13 +-
.../doris/connector/iceberg/IcebergConnector.java | 92 +-
.../iceberg/IcebergConnectorMetadata.java | 11 +-
.../connector/iceberg/IcebergFormatCache.java | 41 +-
.../iceberg/IcebergLatestSnapshotCache.java | 40 +-
.../connector/iceberg/IcebergManifestCache.java | 54 +-
.../iceberg/IcebergNestedColumnEvolution.java | 20 +
.../connector/iceberg/IcebergPartitionCache.java | 41 +-
.../doris/connector/iceberg/IcebergTableCache.java | 49 +-
...BackedIcebergCatalogOpsColumnEvolutionTest.java | 144 ++
.../connector/iceberg/IcebergCommentCacheTest.java | 2 +-
...cebergConnectorMetadataColumnEvolutionTest.java | 47 +
.../connector/iceberg/IcebergFormatCacheTest.java | 2 +-
.../iceberg/IcebergLatestSnapshotCacheTest.java | 2 +-
.../iceberg/IcebergPartitionCacheTest.java | 2 +-
.../connector/iceberg/IcebergTableCacheTest.java | 4 +-
fe/fe-connector/fe-connector-maxcompute/pom.xml | 11 +-
.../maxcompute/MaxComputeDorisConnector.java | 13 +-
.../maxcompute/MaxComputePartitionCache.java | 44 +-
fe/fe-connector/fe-connector-paimon/pom.xml | 10 +-
.../doris/connector/paimon/PaimonConnector.java | 25 +-
.../paimon/PaimonLatestSnapshotCache.java | 34 +-
.../connector/paimon/PaimonScanPlanProvider.java | 26 +-
.../doris/connector/paimon/PaimonScanRange.java | 13 +-
.../doris/connector/paimon/PaimonSchemaAtMemo.java | 56 +-
.../paimon/PaimonLatestSnapshotCacheTest.java | 2 +-
.../paimon/PaimonScanPlanProviderTest.java | 105 +-
.../paimon/PaimonScanRangeReaderTypeTest.java | 18 +-
fe/fe-core/pom.xml | 5 +
.../main/java/org/apache/doris/alter/Alter.java | 126 +-
.../apache/doris/alter/CloudSchemaChangeJobV2.java | 7 +-
.../doris/alter/MaterializedViewHandler.java | 2 +-
.../java/org/apache/doris/alter/RollupJobV2.java | 2 +-
.../apache/doris/alter/SchemaChangeHandler.java | 3 +-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 6 +-
.../apache/doris/analysis/AnalyzeProperties.java | 2 +-
.../apache/doris/analysis/InvertedIndexUtil.java | 24 +-
.../java/org/apache/doris/backup/RestoreJob.java | 7 +-
.../doris/catalog/BuiltinScalarFunctions.java | 43 +-
.../apache/doris/catalog/CatalogRecycleBin.java | 42 +-
.../main/java/org/apache/doris/catalog/Env.java | 98 +-
.../org/apache/doris/catalog/FunctionHelper.java | 19 +-
.../org/apache/doris/catalog/FunctionRegistry.java | 40 +-
.../org/apache/doris/catalog/LocalReplica.java | 30 +
.../main/java/org/apache/doris/catalog/MTMV.java | 297 ++-
.../java/org/apache/doris/catalog/OlapTable.java | 68 +-
.../org/apache/doris/catalog/OlapTableFactory.java | 20 +
.../org/apache/doris/catalog/PartitionInfo.java | 32 +
.../doris/catalog/RecyclePartitionParam.java | 3 +
.../java/org/apache/doris/catalog/Replica.java | 14 +
.../main/java/org/apache/doris/catalog/Table.java | 6 +-
.../java/org/apache/doris/catalog/TableIf.java | 6 +-
.../org/apache/doris/catalog/TableProperty.java | 5 +
.../main/java/org/apache/doris/catalog/Tablet.java | 12 +
.../apache/doris/catalog/TabletInvertedIndex.java | 2 +-
.../java/org/apache/doris/catalog/TabletMeta.java | 8 +-
.../authorizer/ranger/RangerAccessController.java | 11 +-
.../ranger/hive/RangerHiveAccessController.java | 18 +-
.../catalog/stream/TableStreamBuildFactory.java | 1 +
.../clone/ColocateTableCheckerAndBalancer.java | 35 +-
.../java/org/apache/doris/clone/Rebalancer.java | 6 +-
.../RowBinlogRepairReason.java} | 13 +-
.../doris/clone/RowBinlogTabletLocality.java | 400 ++++
.../java/org/apache/doris/clone/TabletChecker.java | 19 +-
.../org/apache/doris/clone/TabletSchedCtx.java | 109 +
.../org/apache/doris/clone/TabletScheduler.java | 514 ++++-
.../apache/doris/clone/TabletSchedulerStat.java | 4 +
.../doris/cloud/CacheHotspotManagerUtils.java | 2 +-
.../cloud/alter/CloudSchemaChangeHandler.java | 24 +
.../apache/doris/cloud/backup/CloudRestoreJob.java | 3 +-
.../cloud/datasource/CloudInternalCatalog.java | 16 +-
.../doris/cloud/load/CloudBrokerLoadJob.java | 8 +
.../transaction/CloudGlobalTransactionMgr.java | 2 +-
.../doris/common/cache/NereidsSqlCacheManager.java | 9 -
.../common/proc/IncompleteTabletsProcNode.java | 5 +-
.../doris/common/proc/PartitionsProcDir.java | 7 +-
.../doris/common/proc/TabletHealthProcDir.java | 48 +-
.../common/proc/TabletSchedulerDetailProcDir.java | 3 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 43 +
.../apache/doris/datasource/ExternalCatalog.java | 57 +-
.../apache/doris/datasource/ExternalDatabase.java | 57 +-
.../doris/datasource/ExternalMetaCacheMgr.java | 67 +-
.../doris/datasource/ExternalRowCountCache.java | 2 +-
.../org/apache/doris/datasource/ExternalTable.java | 13 +-
.../org/apache/doris/datasource/ExternalView.java | 6 +-
.../apache/doris/datasource/InternalCatalog.java | 105 +-
.../converter/ConnectorColumnConverter.java | 2 +-
.../datasource/doris/DorisExternalMetaCache.java | 12 +-
.../datasource/doris/RemoteDorisExternalTable.java | 11 +-
.../doris/datasource/metacache/CacheSpec.java | 287 ---
.../datasource/metacache/CatalogEntryGroup.java | 49 -
.../metacache/CatalogMetaCacheRuntime.java | 90 +
...etaCache.java => ExternalCatalogMetaCache.java} | 107 +-
.../datasource/metacache/ExternalMetaCache.java | 3 +-
.../metacache/ExternalMetaCacheRegistry.java | 99 -
.../metacache/ExternalMetaCacheRouteResolver.java | 66 -
.../datasource/metacache/FeMetaCacheEntry.java | 509 +++++
.../doris/datasource/metacache/IdNameIndex.java | 4 +-
.../doris/datasource/metacache/MetaCacheEntry.java | 835 -------
.../datasource/metacache/MetaCacheEntryDef.java | 16 +-
.../metacache/MetaCacheEntryInvalidation.java | 15 +-
.../datasource/metacache/MetaCacheEntryStats.java | 4 +-
.../mvcc/PluginDrivenMvccExternalTable.java | 2 +-
.../plugin/PluginDrivenExternalTable.java | 12 +-
.../doris/httpv2/rest/TableSchemaAction.java | 20 +-
.../doris/httpv2/rest/response/SchemaTypeDesc.java | 234 ++
.../org/apache/doris/indexpolicy/IndexPolicy.java | 2 +-
.../apache/doris/job/extensions/mtmv/MTMVJob.java | 2 +-
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 894 ++++++--
.../doris/job/extensions/mtmv/MTMVTaskContext.java | 84 +-
.../org/apache/doris/job/task/AbstractTask.java | 4 +-
.../apache/doris/job/util/StreamingJobUtils.java | 2 +-
.../org/apache/doris/journal/JournalEntity.java | 8 +-
.../java/org/apache/doris/load/loadv2/LoadJob.java | 5 +
.../org/apache/doris/master/ReportHandler.java | 36 +
.../org/apache/doris/mtmv/MTMVAlterOpType.java | 3 +-
.../apache/doris/mtmv/MTMVAnalyzeQueryInfo.java | 34 +-
.../main/java/org/apache/doris/mtmv/MTMVCache.java | 2 +-
.../java/org/apache/doris/mtmv/MTMVJobManager.java | 12 +-
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 529 ++++-
.../org/apache/doris/mtmv/MTMVPropertyUtil.java | 175 +-
.../org/apache/doris/mtmv/MTMVRefreshEnum.java | 4 +-
.../org/apache/doris/mtmv/MTMVRefreshInfo.java | 51 +
.../org/apache/doris/mtmv/MTMVRefreshSnapshot.java | 24 +
.../org/apache/doris/mtmv/MTMVRelationManager.java | 62 +-
.../main/java/org/apache/doris/mtmv/ivm/AGENTS.md | 218 ++
.../apache/doris/mtmv/ivm/IvmAggDeltaHandler.java | 490 ++++
.../doris/mtmv/ivm/IvmDeltaRewriteHelper.java | 537 +++++
.../doris/mtmv/ivm/IvmDeltaRewriteResult.java | 43 +
.../doris/mtmv/ivm/IvmDeltaRewriteState.java | 182 ++
.../doris/mtmv/ivm/IvmDeltaRewriteVisitor.java | 121 +
.../apache/doris/mtmv/ivm/IvmDeltaRewriter.java | 165 ++
.../ivm/IvmDryRunLimit.java} | 48 +-
.../ivm/IvmException.java} | 30 +-
.../doris/mtmv/ivm/IvmFailureClassifier.java | 53 +
.../ivm/IvmFailureReason.java} | 40 +-
.../doris/mtmv/ivm/IvmIncrRefreshContext.java | 149 ++
.../doris/mtmv/ivm/IvmIncrRefreshManager.java | 143 ++
.../doris/mtmv/ivm/IvmIncrRefreshResult.java | 67 +
.../java/org/apache/doris/mtmv/ivm/IvmInfo.java | 142 ++
.../apache/doris/mtmv/ivm/IvmJoinDeltaHandler.java | 987 ++++++++
.../doris/mtmv/ivm/IvmLinearDeltaHandler.java | 255 +++
.../apache/doris/mtmv/ivm/IvmPlanSignature.java | 59 +
.../doris/mtmv/ivm/IvmPlanSignatureGenerator.java | 491 ++++
.../apache/doris/mtmv/ivm/IvmRewriteContext.java | 170 ++
.../apache/doris/mtmv/ivm/IvmRewriteResult.java | 115 +
.../doris/mtmv/ivm/IvmSequenceCalculator.java | 133 ++
.../java/org/apache/doris/mtmv/ivm/IvmUtil.java | 314 +++
.../doris/mtmv/ivm/agg/IvmAggApplyContext.java | 120 +
.../doris/mtmv/ivm/agg/IvmAggAvgProcessor.java | 76 +
.../doris/mtmv/ivm/agg/IvmAggBitmapProcessor.java | 116 +
.../ivm/agg/IvmAggBitmapUnionCountProcessor.java | 58 +
.../mtmv/ivm/agg/IvmAggBitmapUnionProcessor.java | 43 +
.../apache/doris/mtmv/ivm/agg/IvmAggColumnKey.java | 75 +
.../doris/mtmv/ivm/agg/IvmAggCountProcessor.java | 103 +
.../doris/mtmv/ivm/agg/IvmAggDeltaSlotRef.java | 62 +
.../mtmv/ivm/agg/IvmAggExpressionBuilder.java | 145 ++
.../mtmv/ivm/agg/IvmAggExtremalProcessor.java | 165 ++
.../ivm/agg/IvmAggFunctionKind.java} | 25 +-
.../mtmv/ivm/agg/IvmAggFunctionProcessor.java | 155 ++
.../doris/mtmv/ivm/agg/IvmAggFunctionRegistry.java | 150 ++
.../doris/mtmv/ivm/agg/IvmAggMaxProcessor.java | 64 +
.../org/apache/doris/mtmv/ivm/agg/IvmAggMeta.java | 75 +
.../doris/mtmv/ivm/agg/IvmAggMinProcessor.java | 64 +
.../ivm/agg/IvmAggStateKey.java} | 13 +-
.../doris/mtmv/ivm/agg/IvmAggSumLikeProcessor.java | 58 +
.../doris/mtmv/ivm/agg/IvmAggSumProcessor.java | 64 +
.../apache/doris/mtmv/ivm/agg/IvmAggTarget.java | 106 +
.../doris/mtmv/ivm/agg/IvmAggTargetSpec.java | 69 +
.../org/apache/doris/mysql/privilege/Auth.java | 27 +-
.../org/apache/doris/nereids/CascadesContext.java | 33 +-
.../java/org/apache/doris/nereids/PlanContext.java | 2 +-
.../org/apache/doris/nereids/StatementContext.java | 30 +-
.../org/apache/doris/nereids/cost/CostModel.java | 4 +-
.../glue/translator/ExpressionTranslator.java | 20 +
.../glue/translator/PhysicalPlanTranslator.java | 47 +-
.../java/org/apache/doris/nereids/jobs/Job.java | 2 +-
.../nereids/jobs/cascades/DeriveStatsJob.java | 2 +-
.../doris/nereids/jobs/executor/Analyzer.java | 6 +
.../jobs/joinorder/hypergraph/GraphSimplifier.java | 2 +-
.../joinorder/hypergraphv2/GraphSimplifier.java | 2 +-
.../java/org/apache/doris/nereids/memo/Group.java | 2 +-
.../apache/doris/nereids/memo/GroupExpression.java | 2 +-
.../nereids/metrics/event/StatsStateEvent.java | 2 +-
.../apache/doris/nereids/minidump/Minidump.java | 4 +-
.../doris/nereids/minidump/MinidumpUtils.java | 6 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 374 +--
.../parser/LogicalPlanBuilderForCreateView.java | 9 +-
.../parser/LogicalPlanBuilderForEncryption.java | 25 +-
.../apache/doris/nereids/parser/NereidsParser.java | 44 +-
.../generator/PatternDescribableProcessor.java | 4 -
.../processor/post/RuntimeFilterGenerator.java | 4 +-
.../processor/post/RuntimeFilterPruner.java | 4 +-
.../post/RuntimeFilterPushDownVisitor.java | 2 +-
.../nereids/processor/post/ShuffleKeyPruner.java | 2 +-
.../properties/ChildrenPropertiesRegulator.java | 4 +-
.../nereids/properties/RequestPropertyDeriver.java | 2 +-
.../nereids/properties/ShuffleKeyPruneUtils.java | 4 +-
.../org/apache/doris/nereids/rules/RuleType.java | 3 +
.../doris/nereids/rules/analysis/BindSink.java | 96 +-
.../nereids/rules/analysis/CheckAnalysis.java | 23 +-
.../analysis/CloudTableStreamReadStateHook.java | 28 +-
.../nereids/rules/analysis/ExpressionAnalyzer.java | 140 +-
.../nereids/rules/analysis/IvmFullRefreshMTMV.java | 140 ++
.../nereids/rules/analysis/IvmIncrRefreshMTMV.java | 112 +
.../nereids/rules/analysis/IvmNormalizeMTMV.java | 1219 ++++++++++
.../nereids/rules/analysis/NormalizeAggregate.java | 29 +-
.../nereids/rules/analysis/NormalizeRepeat.java | 21 +-
.../rules/analysis/WindowFunctionChecker.java | 5 +
.../mv/AbstractMaterializedViewRule.java | 2 +-
.../mv/AsyncMaterializationContext.java | 2 +-
.../exploration/mv/MaterializationContext.java | 23 +-
.../exploration/mv/MaterializedViewUtils.java | 4 +-
.../exploration/mv/SyncMaterializationContext.java | 2 +-
.../mv/rollup/SingleCombinatorRollupHandler.java | 4 +-
.../rules/expression/QueryColumnCollector.java | 2 +-
.../nereids/rules/expression/check/CheckCast.java | 20 +-
...ogicalPartitionTopNToPhysicalPartitionTopN.java | 4 +-
.../rules/implementation/SplitAggMultiPhase.java | 2 +-
.../rewrite/AccessPathExpressionCollector.java | 27 +-
.../rewrite/DecomposeRepeatWithPreAggregation.java | 4 +-
.../rules/rewrite/DistinctAggStrategySelector.java | 4 +-
.../rules/rewrite/DistinctAggregateRewriter.java | 4 +-
.../rules/rewrite/InferSetOperatorDistinct.java | 4 +-
.../LogicalResultSinkToShortCircuitPointQuery.java | 32 +-
.../nereids/rules/rewrite/NestedColumnPruning.java | 14 +-
.../rules/rewrite/PruneOlapScanPartition.java | 12 +-
.../nereids/rules/rewrite/PruneOlapScanTablet.java | 2 +-
.../doris/nereids/rules/rewrite/SkewJoin.java | 2 +-
.../doris/nereids/rules/rewrite/StatsDerive.java | 6 +-
.../rewrite/eageraggregation/EagerAggRewriter.java | 4 +-
.../nereids/stats/ColumnStatsAdjustVisitor.java | 6 +-
.../doris/nereids/stats/ExpressionEstimation.java | 6 +-
.../doris/nereids/stats/FilterEstimation.java | 10 +-
.../doris/nereids/stats/HboStatsCalculator.java | 4 +-
.../apache/doris/nereids/stats/JoinEstimation.java | 8 +-
.../nereids/stats/MemoStatsAndCostRecomputer.java | 2 +-
.../doris/nereids/stats/SimpleAggCacheMgr.java | 2 +-
.../doris/nereids/stats/StatsCalculator.java | 22 +-
.../doris/nereids/stats/StatsErrorEstimator.java | 2 +-
.../functions/AggCombinerFunctionBuilder.java | 31 +-
.../functions/BuiltinFunctionBuilder.java | 21 +-
.../expressions/functions/FunctionBuilder.java | 5 +
.../trees/expressions/functions/LambdaBinding.java | 24 +-
.../expressions/functions/LambdaBindingSpec.java} | 21 +-
.../expressions/functions/LambdaBindingSpecs.java | 191 ++
.../trees/expressions/functions/agg/AIAgg.java | 2 +-
.../functions/agg/NotSupportAggState.java} | 9 +-
.../functions/agg/OrthogonalBitmapFunction.java | 3 +-
.../functions/agg/OrthogonalBitmapUnionCount.java | 2 +-
...StateCombinator.java => CombineCombinator.java} | 101 +-
.../functions/combinator/MergeCombinator.java | 2 +-
.../functions/combinator/StateCombinator.java | 4 +
.../functions/combinator/UnionCombinator.java | 2 +-
.../{MurmurHash364.java => ArrayExceptAll.java} | 61 +-
.../functions/scalar/CreateNamedStruct.java | 3 +-
.../trees/expressions/functions/scalar/Lambda.java | 37 -
.../trees/expressions/functions/scalar/MapAll.java | 90 +
.../expressions/functions/scalar/MapApply.java | 129 ++
.../expressions/functions/scalar/MapExists.java | 90 +
.../expressions/functions/scalar/MapFilter.java | 112 +
.../functions/scalar/MapFromEntries.java | 6 +-
.../functions/scalar/MapFromEntriesUnique.java} | 38 +-
.../scalar/MapFromFilteredEntriesUnique.java} | 33 +-
.../functions/scalar/MapLambdaFunctionUtils.java | 94 +
.../functions/scalar/MurmurHash364.java | 8 +-
.../functions/scalar/TransformKeys.java | 86 +
.../functions/scalar/TransformValues.java | 99 +
.../trees/expressions/functions/table/Numbers.java | 6 +-
.../functions/table/TableValuedFunction.java | 4 +-
.../expressions/functions/udf/JavaUdafBuilder.java | 2 +-
.../expressions/functions/udf/JavaUdfBuilder.java | 2 +-
.../expressions/functions/udf/JavaUdtfBuilder.java | 2 +-
.../functions/udf/PythonUdafBuilder.java | 2 +-
.../functions/udf/PythonUdfBuilder.java | 2 +-
.../functions/udf/PythonUdtfBuilder.java | 2 +-
.../visitor/AggregateFunctionVisitor.java | 5 +
.../expressions/visitor/ScalarFunctionVisitor.java | 35 +
.../doris/nereids/trees/plans/AbstractPlan.java | 2 +-
.../doris/nereids/trees/plans/Explainable.java | 4 +
.../doris/nereids/trees/plans/GroupPlan.java | 2 +-
.../org/apache/doris/nereids/trees/plans/Plan.java | 2 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 1 +
.../plans/commands/AlterColumnStatsCommand.java | 6 +-
.../trees/plans/commands/AlterStreamCommand.java | 112 +
.../plans/commands/AlterTableStatsCommand.java | 2 +-
.../trees/plans/commands/AnalyzeCommand.java | 2 +-
.../trees/plans/commands/AnalyzeTableCommand.java | 2 +-
.../plans/commands/CreateFunctionCommand.java | 13 +-
.../trees/plans/commands/CreateMTMVCommand.java | 193 +-
.../commands/CreateMaterializedViewCommand.java | 5 +
.../trees/plans/commands/ExecuteCommand.java | 15 +-
.../trees/plans/commands/ExplainCommand.java | 78 +-
.../trees/plans/commands/RefreshMTMVCommand.java | 233 +-
.../trees/plans/commands/ShowAnalyzeCommand.java | 2 +-
.../plans/commands/ShowAnalyzeTaskCommand.java | 2 +-
.../commands/ShowColumnHistogramStatsCommand.java | 2 +-
.../plans/commands/ShowColumnStatsCommand.java | 16 +-
.../plans/commands/ShowIndexStatsCommand.java | 2 +-
.../plans/commands/ShowPartitionIdCommand.java | 5 +-
.../commands/ShowQueuedAnalyzeJobsCommand.java | 2 +-
.../plans/commands/ShowTableStatsCommand.java | 4 +-
.../plans/commands/UpdateMvByPartitionCommand.java | 3 +-
.../plans/commands/info/AlterMTMVPropertyInfo.java | 75 +
.../plans/commands/info/AlterMTMVRefreshInfo.java | 48 +
.../trees/plans/commands/info/BaseViewInfo.java | 21 +-
.../plans/commands/info/ColumnDefinition.java | 21 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 285 ++-
.../trees/plans/commands/info/CreateTableInfo.java | 229 +-
.../trees/plans/commands/info/CreateViewInfo.java | 30 +-
.../plans/commands/info/ModifyPartitionOp.java | 7 +-
.../commands/info/ModifyTablePropertiesOp.java | 12 +-
.../trees/plans/commands/info/RefreshMTMVInfo.java | 117 +-
.../commands/insert/AbstractInsertExecutor.java | 39 +-
.../plans/commands/insert/CancelableCommand.java} | 29 +-
.../commands/insert/InsertIntoTableCommand.java | 143 +-
.../insert/InsertOverwriteTableCommand.java | 3 +-
.../insert/OlapGroupCommitInsertExecutor.java | 17 +-
.../plans/commands/insert/OlapInsertExecutor.java | 6 +-
.../commands/insert/OlapTxnInsertExecutor.java | 1 +
.../commands/insert/RemoteOlapInsertExecutor.java | 19 +-
.../insert/StreamConsumptionInfoExtractor.java | 2 +-
.../trees/plans/logical/LogicalOlapScan.java | 27 +
.../plans/logical/LogicalOlapTableStreamScan.java | 79 +-
.../nereids/trees/plans/logical/LogicalRepeat.java | 20 +-
.../trees/plans/physical/AbstractPhysicalJoin.java | 2 +-
.../trees/plans/physical/AbstractPhysicalPlan.java | 2 +-
.../trees/plans/physical/AbstractPhysicalSort.java | 2 +-
.../plans/physical/PhysicalAssertNumRows.java | 2 +-
.../physical/PhysicalBaseExternalTableSink.java | 2 +-
.../trees/plans/physical/PhysicalBinary.java | 2 +-
.../plans/physical/PhysicalBlackholeSink.java | 2 +-
.../trees/plans/physical/PhysicalCTEAnchor.java | 2 +-
.../trees/plans/physical/PhysicalCTEConsumer.java | 2 +-
.../trees/plans/physical/PhysicalCTEProducer.java | 2 +-
.../plans/physical/PhysicalCatalogRelation.java | 2 +-
.../plans/physical/PhysicalConnectorTableSink.java | 2 +-
.../plans/physical/PhysicalDictionarySink.java | 2 +-
.../trees/plans/physical/PhysicalDistribute.java | 2 +-
.../plans/physical/PhysicalEmptyRelation.java | 2 +-
.../trees/plans/physical/PhysicalExcept.java | 2 +-
.../PhysicalExternalRowLevelDeleteSink.java | 2 +-
.../PhysicalExternalRowLevelMergeSink.java | 2 +-
.../trees/plans/physical/PhysicalFileScan.java | 2 +-
.../trees/plans/physical/PhysicalFileSink.java | 2 +-
.../trees/plans/physical/PhysicalFilter.java | 2 +-
.../trees/plans/physical/PhysicalGenerate.java | 2 +-
.../plans/physical/PhysicalHashAggregate.java | 2 +-
.../trees/plans/physical/PhysicalHashJoin.java | 2 +-
.../trees/plans/physical/PhysicalIntersect.java | 2 +-
.../plans/physical/PhysicalLazyMaterialize.java | 2 +-
.../physical/PhysicalLazyMaterializeOlapScan.java | 2 +-
.../physical/PhysicalLazyMaterializeTVFScan.java | 2 +-
.../nereids/trees/plans/physical/PhysicalLeaf.java | 2 +-
.../trees/plans/physical/PhysicalLimit.java | 2 +-
.../plans/physical/PhysicalNestedLoopJoin.java | 2 +-
.../trees/plans/physical/PhysicalOdbcScan.java | 2 +-
.../trees/plans/physical/PhysicalOlapScan.java | 2 +-
.../plans/physical/PhysicalOlapTableSink.java | 2 +-
.../plans/physical/PhysicalOneRowRelation.java | 2 +-
.../plans/physical/PhysicalPartitionTopN.java | 2 +-
.../nereids/trees/plans/physical/PhysicalPlan.java | 2 +-
.../trees/plans/physical/PhysicalProject.java | 2 +-
.../trees/plans/physical/PhysicalQuickSort.java | 2 +-
.../plans/physical/PhysicalRecursiveUnion.java | 2 +-
.../physical/PhysicalRecursiveUnionAnchor.java | 2 +-
.../physical/PhysicalRecursiveUnionProducer.java | 2 +-
.../trees/plans/physical/PhysicalRelation.java | 2 +-
.../trees/plans/physical/PhysicalRepeat.java | 2 +-
.../trees/plans/physical/PhysicalResultSink.java | 2 +-
.../trees/plans/physical/PhysicalSchemaScan.java | 2 +-
.../trees/plans/physical/PhysicalSetOperation.java | 2 +-
.../nereids/trees/plans/physical/PhysicalSink.java | 2 +-
.../trees/plans/physical/PhysicalSqlCache.java | 2 +-
.../physical/PhysicalStorageLayerAggregate.java | 2 +-
.../trees/plans/physical/PhysicalTVFRelation.java | 2 +-
.../trees/plans/physical/PhysicalTVFTableSink.java | 2 +-
.../trees/plans/physical/PhysicalTableSink.java | 2 +-
.../nereids/trees/plans/physical/PhysicalTopN.java | 2 +-
.../trees/plans/physical/PhysicalUnary.java | 2 +-
.../trees/plans/physical/PhysicalUnion.java | 2 +-
.../trees/plans/physical/PhysicalWindow.java | 2 +-
.../plans/physical/PhysicalWorkTableReference.java | 2 +-
.../trees/plans/visitor/CommandVisitor.java | 5 +
.../visitor/NondeterministicFunctionCollector.java | 23 +-
.../apache/doris/nereids/types/AggStateType.java | 15 +-
.../org/apache/doris/nereids/types/DataType.java | 4 +-
.../apache/doris/nereids/types/StructField.java | 45 +-
.../org/apache/doris/nereids/types/StructType.java | 22 +-
.../apache/doris/nereids/util/AggregateUtils.java | 4 +-
.../doris/nereids/util/TypeCoercionUtils.java | 4 +
.../java/org/apache/doris/nereids/util/Utils.java | 2 +-
.../java/org/apache/doris/persist/AlterMTMV.java | 11 +
.../java/org/apache/doris/persist/EditLog.java | 10 +-
.../apache/doris/persist/PartitionPersistInfo.java | 16 +
.../doris/planner/HashDistributionPruner.java | 44 +-
.../org/apache/doris/planner/OlapScanNode.java | 21 +-
.../java/org/apache/doris/planner/ScanNode.java | 10 +-
.../java/org/apache/doris/qe/ConnectContext.java | 4 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 10 +-
.../java/org/apache/doris/qe/FEOpExecutor.java | 1 +
.../org/apache/doris/qe/PointQueryExecutor.java | 2 +-
.../java/org/apache/doris/qe/ResultReceiver.java | 13 +-
.../java/org/apache/doris/qe/SessionVariable.java | 30 +-
.../apache/doris/qe/ShortCircuitQueryContext.java | 6 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 202 +-
.../doris/qe/TimeBasedChangeVisibleWaiter.java | 72 +-
.../main/java/org/apache/doris/qe/VariableMgr.java | 1 +
.../apache/doris/service/FrontendServiceImpl.java | 20 +-
.../java/org/apache/doris/statistics/README.md | 14 +
.../statistics/{ => analysis}/AnalysisInfo.java | 2 +-
.../{ => analysis}/AnalysisInfoBuilder.java | 10 +-
.../statistics/{ => analysis}/AnalysisJob.java | 4 +-
.../statistics/{ => analysis}/AnalysisManager.java | 17 +-
.../statistics/{ => analysis}/AnalysisState.java | 2 +-
.../{ => analysis}/AnalysisTaskExecutor.java | 2 +-
.../{ => analysis}/AnalysisTaskWrapper.java | 4 +-
.../{ => analysis}/AnalyzeSkipException.java | 2 +-
.../{ => analysis}/AutoAnalysisPendingJob.java | 2 +-
.../{ => analysis}/BaseAnalysisTask.java | 8 +-
.../statistics/{ => analysis}/ColStatsMeta.java | 8 +-
.../{ => analysis}/ExternalAnalysisTask.java | 3 +-
.../{ => analysis}/FollowerColumnSender.java | 2 +-
.../statistics/{ => analysis}/HistogramTask.java | 5 +-
.../statistics/{ => analysis}/JobPriority.java | 2 +-
.../{ => analysis}/NewPartitionLoadedEvent.java | 2 +-
.../{ => analysis}/OlapAnalysisTask.java | 7 +-
.../PluginDrivenSampleAnalysisTask.java | 2 +-
.../statistics/{ => analysis}/QueryColumn.java | 2 +-
.../{ => analysis}/StatisticsAutoCollector.java | 9 +-
.../{ => analysis}/StatisticsJobAppender.java | 3 +-
.../{ => analysis}/StatisticsMetricCollector.java | 3 +-
.../statistics/{ => analysis}/StatsCategory.java | 2 +-
.../{ => analysis}/StatsGranularity.java | 2 +-
.../statistics/{ => analysis}/TableStatsMeta.java | 4 +-
.../{ => analysis}/TaskStatusWrapper.java | 2 +-
.../statistics/{ => analysis}/UpdateRowsEvent.java | 2 +-
.../package-info.java} | 11 +-
.../{ => cache}/BasicAsyncCacheLoader.java | 2 +-
.../{ => cache}/ColumnStatisticsCacheLoader.java | 5 +-
.../{ => cache}/HistogramCacheLoader.java | 5 +-
.../{ => cache}/InvalidateStatsTarget.java | 2 +-
.../PartitionColumnStatisticCacheKey.java | 2 +-
.../PartitionColumnStatisticCacheLoader.java | 5 +-
.../statistics/{ => cache}/StatisticsCache.java | 10 +-
.../statistics/{ => cache}/StatisticsCacheKey.java | 2 +-
.../{ => cache}/UpdatePartitionStatsTarget.java | 2 +-
.../{JobPriority.java => cache/package-info.java} | 11 +-
.../doris/statistics/{ => model}/Bucket.java | 2 +-
.../statistics/{ => model}/ColumnStatistic.java | 4 +-
.../{ => model}/ColumnStatisticBuilder.java | 2 +-
.../doris/statistics/{ => model}/ExprStats.java | 2 +-
.../doris/statistics/{ => model}/Histogram.java | 4 +-
.../statistics/{ => model}/HistogramBuilder.java | 2 +-
.../{ => model}/PartitionColumnStatistic.java | 3 +-
.../PartitionColumnStatisticBuilder.java | 2 +-
.../{ => model}/SlotStatsDeriveResult.java | 2 +-
.../statistics/{ => model}/StatisticRange.java | 2 +-
.../doris/statistics/{ => model}/Statistics.java | 2 +-
.../statistics/{ => model}/StatisticsBuilder.java | 2 +-
.../statistics/{ => model}/StatsDeriveResult.java | 2 +-
.../doris/statistics/{ => model}/StatsType.java | 2 +-
.../{JobPriority.java => model/package-info.java} | 11 +-
.../{ExprStats.java => package-info.java} | 19 +-
.../statistics/{ => repository}/ColStatsData.java | 4 +-
.../statistics/{ => repository}/HistData.java | 2 +-
.../statistics/{ => repository}/ResultRow.java | 2 +-
.../{ => repository}/StatisticsCleaner.java | 5 +-
.../{ => repository}/StatisticsRepository.java | 9 +-
.../doris/statistics/{ => repository}/StatsId.java | 2 +-
.../package-info.java} | 11 +-
.../doris/statistics/util/StatisticsUtil.java | 16 +-
.../ExternalFileTableValuedFunction.java | 10 +-
.../doris/tablefunction/MetadataGenerator.java | 57 +-
.../tablefunction/MvInfosTableValuedFunction.java | 3 +-
.../PartitionsTableValuedFunction.java | 5 +-
.../doris/tablefunction/TableBinlogFunction.java | 13 +-
.../doris/transaction/DatabaseTransactionMgr.java | 18 +-
.../doris/alter/CloudSchemaChangeJobV2Test.java | 44 +
.../InvertedIndexKuromojiValidationTest.java | 50 +
.../analysis/InvertedIndexPropertiesTest.java | 34 +
.../org/apache/doris/backup/CatalogMocker.java | 13 +-
.../doris/catalog/AlterTableStreamCommentTest.java | 120 +
.../doris/catalog/CatalogRecycleBinTest.java | 95 +-
.../org/apache/doris/catalog/CatalogTestUtil.java | 5 +-
.../doris/catalog/ColumnGsonSerializationTest.java | 72 +
.../apache/doris/catalog/CreateFunctionTest.java | 33 +
.../org/apache/doris/catalog/CreateTableTest.java | 31 +
.../org/apache/doris/catalog/CreateViewTest.java | 26 +
.../doris/catalog/DropMaterializedViewTest.java | 84 +
.../doris/catalog/MaterializedIndexTest.java | 57 +-
.../org/apache/doris/catalog/OlapTableTest.java | 120 +
.../apache/doris/catalog/RefreshManagerTest.java | 39 +-
.../apache/doris/catalog/ShowCreateMTMVTest.java | 328 +++
.../apache/doris/catalog/TablePropertyTest.java | 11 +
.../java/org/apache/doris/catalog/TabletTest.java | 64 +-
.../hive/RangerHiveAccessControllerTest.java | 62 +
.../doris/clone/ClusterLoadStatisticsTest.java | 9 +-
.../clone/ColocateTableCheckerAndBalancerTest.java | 155 ++
.../org/apache/doris/clone/DiskRebalanceTest.java | 2 +
.../java/org/apache/doris/clone/RebalanceTest.java | 1 +
.../org/apache/doris/clone/RebalancerTestUtil.java | 2 +-
.../doris/clone/RowBinlogRebalancerTest.java | 137 ++
.../doris/clone/RowBinlogTabletLocalityTest.java | 472 ++++
.../doris/clone/RowBinlogTabletSchedulerTest.java | 649 ++++++
.../cloud/alter/CloudSchemaChangeHandlerTest.java | 92 +
.../cloud/datasource/CloudInternalCatalogTest.java | 84 +
.../doris/cloud/load/CloudBrokerLoadJobTest.java | 35 +
.../doris/cluster/DecommissionBackendTest.java | 3 +-
.../org/apache/doris/common/CacheFactoryTest.java | 2 +-
.../apache/doris/common/PropertyAnalyzerTest.java | 42 +
.../common/proc/CloudProcVersionDisplayTest.java | 2 +-
.../apache/doris/common/proc/ProcServiceTest.java | 3 +-
.../doris/common/proc/TabletHealthProcDirTest.java | 116 +-
.../org/apache/doris/common/util/UnitTestUtil.java | 3 +-
...teTableInfoToConnectorRequestConverterTest.java | 16 +
.../doris/datasource/ExternalCatalogTest.java | 106 +-
.../doris/datasource/ExternalDatabaseTest.java | 97 +-
.../doris/datasource/InternalCatalogTest.java | 2 +-
.../datasource/RoundRobinCreateTabletTest.java | 3 +-
.../converter/ConnectorColumnConverterTest.java | 43 +
.../doris/DorisExternalMetaCacheTest.java | 4 +-
.../doris/datasource/metacache/CacheSpecTest.java | 10 +-
...Test.java => ExternalCatalogMetaCacheTest.java} | 20 +-
.../datasource/metacache/FeMetaCacheEntryTest.java | 667 ++++++
.../metacache/MetaCacheDeadlockTest.java | 7 +-
.../datasource/metacache/MetaCacheEntryTest.java | 1731 --------------
.../PluginDrivenExternalTableColumnStatTest.java | 2 +-
.../org/apache/doris/http/DorisHttpTestCase.java | 2 +-
.../apache/doris/http/TableSchemaActionTest.java | 12 +
.../rest/TableSchemaActionColumnInfoTest.java | 172 ++
.../httpv2/rest/response/SchemaTypeDescTest.java | 306 +++
.../extensions/mtmv/MTMVTaskContextCompatTest.java | 141 ++
.../java/org/apache/doris/load/DeleteJobTest.java | 3 +-
.../org/apache/doris/load/loadv2/LoadJobTest.java | 9 +
.../doris/master/RowBinlogReportHandlerTest.java | 100 +
.../java/org/apache/doris/mtmv/AlterMTMVTest.java | 526 +++++
.../org/apache/doris/mtmv/MTMVConcurrentTest.java | 4 +-
.../org/apache/doris/mtmv/MTMVJobManagerTest.java | 3 +-
.../org/apache/doris/mtmv/MTMVPlanUtilTest.java | 349 ++-
.../apache/doris/mtmv/MTMVPropertyUtilTest.java | 216 ++
.../apache/doris/mtmv/MTMVRelationManagerTest.java | 53 +
.../org/apache/doris/mtmv/MTMVRewriteUtilTest.java | 6 +-
.../java/org/apache/doris/mtmv/MTMVTaskTest.java | 889 +++++++-
.../test/java/org/apache/doris/mtmv/MTMVTest.java | 224 +-
.../doris/mtmv/ivm/IvmAggDeltaHandlerTest.java | 751 ++++++
.../doris/mtmv/ivm/IvmBaselineRebuildTest.java | 582 +++++
.../doris/mtmv/ivm/IvmDeltaRewriteHelperTest.java | 330 +++
.../doris/mtmv/ivm/IvmDeltaRewriteStateTest.java | 207 ++
.../doris/mtmv/ivm/IvmDeltaRewriterTest.java | 439 ++++
.../apache/doris/mtmv/ivm/IvmDeltaTestBase.java | 491 ++++
.../doris/mtmv/ivm/IvmFailureReasonTest.java} | 26 +-
.../doris/mtmv/ivm/IvmIncrRefreshManagerTest.java | 254 +++
.../org/apache/doris/mtmv/ivm/IvmInfoTest.java | 95 +
.../doris/mtmv/ivm/IvmJoinDeltaHandlerTest.java | 890 ++++++++
.../doris/mtmv/ivm/IvmLinearDeltaHandlerTest.java | 867 +++++++
.../doris/mtmv/ivm/IvmNormalizeMTMVJoinTest.java | 1027 +++++++++
.../doris/mtmv/ivm/IvmNormalizeMTMVUnionTest.java | 321 +++
.../mtmv/ivm/IvmPlanSignatureGeneratorTest.java | 529 +++++
.../doris/mtmv/ivm/IvmRewriteContextTest.java | 103 +
.../doris/mtmv/ivm/IvmSequenceCalculatorTest.java | 96 +
.../org/apache/doris/mtmv/ivm/IvmUtilTest.java | 239 ++
.../doris/mtmv/ivm/agg/IvmAggAvgProcessorTest.java | 104 +
.../agg/IvmAggBitmapUnionCountProcessorTest.java | 59 +
.../ivm/agg/IvmAggBitmapUnionProcessorTest.java | 54 +
.../mtmv/ivm/agg/IvmAggColumnSharingTest.java | 176 ++
.../mtmv/ivm/agg/IvmAggCountProcessorTest.java | 74 +
.../doris/mtmv/ivm/agg/IvmAggMaxProcessorTest.java | 62 +
.../doris/mtmv/ivm/agg/IvmAggMinProcessorTest.java | 62 +
.../mtmv/ivm/agg/IvmAggProcessorTestBase.java | 132 ++
.../doris/mtmv/ivm/agg/IvmAggSumProcessorTest.java | 54 +
.../apache/doris/nereids/cost/CostModelV1Test.java | 4 +-
.../translator/PhysicalPlanTranslatorTest.java | 89 +
.../nereids/jobs/cascades/DeriveStatsJobTest.java | 2 +-
.../doris/nereids/mv/IdStatisticsMapTest.java | 2 +-
.../doris/nereids/parser/LeanTokenModeTest.java | 123 +
.../doris/nereids/parser/NereidsParserTest.java | 54 +-
.../parser/ParseInsertPartitionSpecTest.java | 32 +-
.../nereids/parser/PrimaryExpressionAstTest.java | 128 ++
.../parser/QueryOrDmlCommonPrefixPlanTest.java | 95 +
.../nereids/parser/QueryOrganizationPlanTest.java | 84 +
.../properties/RequestPropertyDeriverTest.java | 4 +-
.../properties/ShuffleKeyPruneUtilsTest.java | 6 +-
.../rules/analysis/ExpressionAnalyzerTest.java | 101 +
.../rules/analysis/FillUpMissingSlotsTest.java | 23 +
.../rules/analysis/FunctionRegistryTest.java | 19 +
.../rules/analysis/IvmFullRefreshMTMVTest.java | 338 +++
.../rules/analysis/IvmIncrRefreshMTMVTest.java | 366 +++
.../rules/analysis/IvmNormalizeMTMVTest.java | 1454 ++++++++++++
.../rules/analysis/NormalizeRepeatTest.java | 40 +
.../rules/exploration/IntersectReorderTest.java | 2 +-
.../rewrite/AccessPathExpressionCollectorTest.java | 102 +
.../DecomposeRepeatWithPreAggregationTest.java | 6 +-
.../rewrite/DistinctAggregateRewriterTest.java | 6 +-
.../rewrite/InferSetOperatorDistinctTest.java | 4 +-
.../rules/rewrite/PruneNestedColumnTest.java | 23 +
.../rules/rewrite/PullUpJoinFromUnionAllTest.java | 33 +
.../rules/rewrite/RewriteRuleSuiteTest.java | 12 +-
.../rules/rewrite/ShortCircuitPointQueryTest.java | 150 +-
.../apache/doris/nereids/sqltest/SqlTestBase.java | 4 +-
.../nereids/stats/ExpressionEstimationTest.java | 6 +-
.../doris/nereids/stats/FilterEstimationTest.java | 8 +-
.../doris/nereids/stats/JoinEstimateTest.java | 8 +-
.../stats/MemoStatsAndCostRecomputerTest.java | 8 +-
.../doris/nereids/stats/StatsCalculatorTest.java | 10 +-
.../apache/doris/nereids/stats/StatsTestUtil.java | 4 +-
.../combinator/CombineCombinatorTest.java | 248 ++
.../functions/scalar/MapLambdaFunctionsTest.java | 285 +++
.../functions/udf/UdfBuilderArityTest.java | 68 +
.../expressions/literal/StructLiteralTest.java | 20 +
.../nereids/trees/plans/CreateMTMVCommandTest.java | 2380 ++++++++++++++++++++
.../trees/plans/CreateTableCommandTest.java | 242 +-
.../doris/nereids/trees/plans/PlanVisitorTest.java | 10 +-
.../nereids/trees/plans/algebra/RepeatTest.java | 26 +
.../plans/commands/AnalyzeTableCommandTest.java | 2 +-
.../commands/ExplainRefreshMTMVCommandTest.java | 566 +++++
.../plans/commands/RefreshMTMVCommandTest.java | 219 ++
.../commands/UpdateMvByPartitionCommandTest.java | 317 ++-
.../plans/commands/info/ModifyPartitionOpTest.java | 81 +
.../commands/info/RefreshMTMVInfoAnalyzeTest.java | 364 +++
.../InsertIntoTableCommandTableStreamTest.java | 137 +-
.../insert/InsertIntoTableCommandTest.java | 124 +
.../commands/insert/OlapInsertExecutorTest.java | 44 +-
.../trees/plans/logical/LogicalOlapScanTest.java | 25 +
.../doris/nereids/util/HyperGraphBuilder.java | 6 +-
.../doris/nereids/util/HyperGraphBuilderOld.java | 6 +-
.../doris/planner/HashDistributionPrunerTest.java | 48 +-
.../org/apache/doris/planner/OlapScanNodeTest.java | 61 +-
.../doris/qe/ShortCircuitQueryContextTest.java | 29 +
.../java/org/apache/doris/qe/StmtExecutorTest.java | 15 +
.../doris/qe/TimeBasedChangeVisibleWaiterTest.java | 54 +
.../doris/service/FrontendServiceImplTest.java | 54 +-
.../org/apache/doris/statistics/StatsMockUtil.java | 2 +
.../statistics/{ => analysis}/AnalysisJobTest.java | 5 +-
.../{ => analysis}/AnalysisManagerTest.java | 10 +-
.../{ => analysis}/AnalysisTaskExecutorTest.java | 8 +-
.../{ => analysis}/AnalysisTaskWrapperTest.java | 4 +-
.../statistics/{ => analysis}/AnalyzeTest.java | 8 +-
.../{ => analysis}/BaseAnalysisTaskTest.java | 5 +-
.../{ => analysis}/FollowerColumnSenderTest.java | 2 +-
.../{ => analysis}/HistogramTaskTest.java | 8 +-
.../{ => analysis}/MVStatisticsTest.java | 3 +-
.../{ => analysis}/OlapAnalysisTaskTest.java | 10 +-
.../StatisticsAutoCollectorTest.java | 4 +-
.../{ => analysis}/StatisticsJobAppenderTest.java | 2 +-
.../{ => analysis}/TableStatsMetaTest.java | 2 +-
.../doris/statistics/{ => cache}/CacheTest.java | 11 +-
.../{ => cache}/StatisticsCacheTest.java | 5 +-
.../statistics/{ => model}/HistogramTest.java | 2 +-
.../statistics/{ => model}/StatisticsTest.java | 2 +-
.../{ => repository}/ColStatsDataTest.java | 3 +-
.../{ => repository}/StatisticsCleanerTest.java | 5 +-
.../doris/statistics/util/StatisticsUtilTest.java | 6 +-
.../ExternalFileTableValuedFunctionTest.java | 42 +
.../transaction/DatabaseTransactionMgrTest.java | 86 +
.../apache/doris/utframe/TestWithFeService.java | 6 +-
.../IdentifierPostProcessorBenchmark.java | 108 +
.../benchmark/LeanTokenModeBenchmark.java | 104 +
.../benchmark/LocalRulePrefixBenchmark.java | 193 ++
.../benchmark/PrimaryExpressionBenchmark.java | 111 +
.../benchmark/QueryOrDmlCommonPrefixBenchmark.java | 113 +
.../benchmark/QueryOrganizationBenchmark.java | 119 +
fe/fe-sql-parser/README.md | 18 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 14 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 484 +++-
.../apache/doris/nereids/parser/PostProcessor.java | 71 -
.../org/apache/doris/sqlparser/DorisSqlParser.java | 3 -
.../sqlparser/DorisLexerLeanTokenModeTest.java | 143 ++
.../apache/doris/sqlparser/DorisSqlParserTest.java | 87 +
.../doris/sqlparser/LimitClausePrefixTest.java | 62 +
.../doris/sqlparser/PrimaryExpressionTest.java | 153 ++
.../sqlparser/QueryOrDmlCommonPrefixTest.java | 106 +
.../sqlparser/QueryOrganizationBehaviorTest.java | 142 ++
.../doris/sqlparser/StatementBaseDispatchTest.java | 160 ++
fe/fe-thrift/pom.xml | 38 +-
.../java/org/apache/doris/catalog/StructField.java | 39 +-
.../java/org/apache/doris/catalog/StructType.java | 23 +-
.../main/java/org/apache/doris/catalog/Type.java | 2 +-
fe/pom.xml | 2 +-
gensrc/proto/cloud.proto | 2 +-
gensrc/proto/olap_file.proto | 11 +
gensrc/thrift/AgentService.thrift | 2 +-
gensrc/thrift/FrontendService.thrift | 1 +
gensrc/thrift/PaloInternalService.thrift | 2 +-
gensrc/thrift/PlanNodes.thrift | 1 +
.../agg_state/avg/test_agg_state_avg.out | 12 +
.../test_iceberg_struct_schema_evolution.out | 4 +-
.../external_table_p0/tvf/test_partitions_tvf.out | 4 +-
regression-test/data/mtmv_ivm_restart_p0/test.out | 7 +
.../data/mtmv_p0/ivm/test_ivm_agg_1.out | 90 +
.../data/mtmv_p0/ivm/test_ivm_agg_2.out | 70 +
.../data/mtmv_p0/ivm/test_ivm_agg_3.out | 67 +
.../data/mtmv_p0/ivm/test_ivm_agg_4.out | 87 +
.../data/mtmv_p0/ivm/test_ivm_agg_5.out | 31 +
.../data/mtmv_p0/ivm/test_ivm_agg_6.out | 13 +
.../data/mtmv_p0/ivm/test_ivm_agg_join_1.out | 60 +
.../data/mtmv_p0/ivm/test_ivm_agg_join_2.out | 71 +
.../data/mtmv_p0/ivm/test_ivm_agg_join_3.out | 6 +
.../data/mtmv_p0/ivm/test_ivm_agg_outer_join_1.out | 18 +
.../mtmv_p0/ivm/test_ivm_agg_shared_columns.out | 101 +
.../data/mtmv_p0/ivm/test_ivm_basic_mtmv.out | 67 +
.../data/mtmv_p0/ivm/test_ivm_bitmap_agg_1.out | 73 +
.../data/mtmv_p0/ivm/test_ivm_bitmap_agg_2.out | 31 +
.../ivm/test_ivm_bitmap_runtime_fallback.out | 13 +
.../data/mtmv_p0/ivm/test_ivm_chained_mtmv_1.out | 25 +
.../data/mtmv_p0/ivm/test_ivm_chained_mtmv_2.out | 47 +
.../mtmv_p0/ivm/test_ivm_create_if_not_exists.out | 27 +
.../mtmv_p0/ivm/test_ivm_cross_db_same_name.out | 19 +
.../mtmv_p0/ivm/test_ivm_cross_db_single_base.out | 18 +
.../data/mtmv_p0/ivm/test_ivm_cube_repeat.out | 74 +
.../data/mtmv_p0/ivm/test_ivm_decimal_avg.out | 12 +
.../ivm/test_ivm_drop_column_fallback_reason.out | 22 +
.../test_ivm_dup_excluded_no_binlog_fallback.out | 8 +
.../mtmv_p0/ivm/test_ivm_dup_keys_lsn_rowid.out | 60 +
.../data/mtmv_p0/ivm/test_ivm_dup_keys_mtmv.out | 13 +
.../ivm/test_ivm_excluded_trigger_table.out | 39 +
.../ivm/test_ivm_execution_failure_no_fallback.out | 11 +
.../data/mtmv_p0/ivm/test_ivm_explain_refresh.out | 47 +
.../test_ivm_full_outer_join_residual_update.out | 6 +
.../data/mtmv_p0/ivm/test_ivm_hidden_columns.out | 34 +
.../data/mtmv_p0/ivm/test_ivm_inner_join_1.out | 75 +
.../data/mtmv_p0/ivm/test_ivm_inner_join_2.out | 63 +
.../ivm/test_ivm_inner_join_update_delete.out | 4 +
.../ivm/test_ivm_minmax_runtime_fallback.out | 13 +
.../data/mtmv_p0/ivm/test_ivm_mtmv_row_binlog.out | 13 +
.../ivm/test_ivm_nested_outer_join_create.out | 51 +
.../data/mtmv_p0/ivm/test_ivm_nullable_row_id.out | 30 +
.../mtmv_p0/ivm/test_ivm_one_row_relation_1.out | 63 +
.../ivm/test_ivm_one_row_relation_partitioned.out | 47 +
.../data/mtmv_p0/ivm/test_ivm_outer_join_1.out | 44 +
.../data/mtmv_p0/ivm/test_ivm_outer_join_2.out | 52 +
.../data/mtmv_p0/ivm/test_ivm_outer_join_3.out | 28 +
.../data/mtmv_p0/ivm/test_ivm_outer_join_4.out | 32 +
.../data/mtmv_p0/ivm/test_ivm_outer_join_5.out | 29 +
.../data/mtmv_p0/ivm/test_ivm_outer_join_6.out | 38 +
.../ivm/test_ivm_outer_join_union_null_side.out | 25 +
.../ivm/test_ivm_partition_baseline_rebuild.out | 22 +
.../mtmv_p0/ivm/test_ivm_partition_sync_retry.out | 4 +
.../mtmv_p0/ivm/test_ivm_partition_unique_key.out | 25 +
.../ivm/test_ivm_partition_window_limit.out | 31 +
.../ivm/test_ivm_partition_window_remove.out | 40 +
.../ivm/test_ivm_plan_signature_fallback.out | 13 +
.../data/mtmv_p0/ivm/test_ivm_refresh_dry_run.out | 25 +
.../data/mtmv_p0/ivm/test_ivm_repeat_1.out | 62 +
.../data/mtmv_p0/ivm/test_ivm_repeat_2.out | 64 +
.../data/mtmv_p0/ivm/test_ivm_repeat_join_1.out | 112 +
.../ivm/test_ivm_replace_stream_cleanup.out | 18 +
.../ivm/test_ivm_replace_table_reconcile.out | 16 +
.../mtmv_p0/ivm/test_ivm_rewrite_projection.out | 9 +
.../ivm/test_ivm_sequence_delta_overwrite.out | 10 +
.../data/mtmv_p0/ivm/test_ivm_snapshot.out | 18 +
...test_ivm_strict_failure_partition_atomicity.out | 17 +
.../data/mtmv_p0/ivm/test_ivm_subquery_alias_1.out | 15 +
.../data/mtmv_p0/ivm/test_ivm_subquery_alias_2.out | 18 +
.../data/mtmv_p0/ivm/test_ivm_subquery_alias_3.out | 15 +
.../data/mtmv_p0/ivm/test_ivm_union_1.out | 100 +
.../data/mtmv_p0/ivm/test_ivm_union_2.out | 96 +
.../data/mtmv_p0/ivm/test_ivm_union_3.out | 54 +
.../ivm/test_ivm_union_delete_same_base.out | 15 +
.../data/mtmv_p0/ivm/test_ivm_use_full_keys_1.out | 53 +
.../data/mtmv_p0/ivm/test_ivm_use_full_keys_2.out | 47 +
.../data/mtmv_p0/ivm/test_ivm_use_full_keys_3.out | 19 +
.../data/mtmv_p0/ivm/test_ivm_use_full_keys_4.out | 19 +
.../data/mtmv_p0/ivm/test_ivm_use_full_keys_5.out | 27 +
.../data/mtmv_p0/ivm/test_ivm_use_full_keys_6.out | 85 +
.../mtmv_p0/ivm/test_ivm_varchar_key_rowid.out | 79 +
.../mtmv_p0/test_auto_refresh_complete_method.out | 20 +
regression-test/data/mtmv_p0/test_commit_mtmv.out | 10 +-
.../mtmv_p0/test_excluded_trigger_table_mtmv.out | 14 +
.../test_point_query_partition_not_exists.out | 21 +
.../array_functions/test_array_except_all.out | 72 +
.../map_functions/test_map_lambda.out | 122 +
.../test_ranger_hive_lowercase_access_type.out | 7 +
.../test_row_binlog_flexible_partial_update.out | 69 +
..._binlog_flexible_partial_update_no_sequence.out | 44 +
.../test_table_stream_alter_comment.out | 19 +
regression-test/framework/pom.xml | 36 +-
regression-test/pipeline/common/github-utils.sh | 1 -
regression-test/plugins/plugin_planner.groovy | 23 +
.../test_point_query_over_arrow_flight.groovy | 131 ++
.../test_sql_cache_over_arrow_flight.groovy | 168 ++
.../auth_p0/test_mysql_user_visibility.groovy | 74 +
...t_cloud_single_rowset_grouped_compaction.groovy | 563 +++++
...rtition_cloud_add_build_index_validation.groovy | 209 ++
...st_partition_cloud_inverted_index_format.groovy | 199 ++
...d_index_storage_format_meta_write_switch.groovy | 247 ++
...ed_index_storage_format_recycle_truncate.groovy | 158 ++
...ud_inverted_index_storage_format_rollout.groovy | 507 +++++
...erted_index_storage_format_rowset_schema.groovy | 165 ++
...nverted_index_storage_format_stream_load.groovy | 196 ++
.../agg_state/avg/test_agg_state_avg.groovy | 72 +
.../PAIMON_ICEBERG_READ_WRITE_P0_COVERAGE.md | 2 +-
.../adbc/test_adbc_type_mapping.groovy | 7 +-
.../test_iceberg_struct_schema_evolution.groovy | 6 +-
.../test_iceberg_write_ctas_format_boundary.groovy | 84 +-
.../paimon/paimon_data_system_table.groovy | 2 -
.../test_paimon_partition_pk_delete_refs.groovy | 3 -
...test_paimon_partition_schema_filter_refs.groovy | 3 -
...der.groovy => test_paimon_reader_parity.groovy} | 19 +-
.../test_paimon_schema_time_travel_matrix.groovy | 30 +-
.../http_rest_api/get/test_schema_api.groovy | 58 +-
.../test_group_commit_replay_wal.groovy | 3 +-
.../transaction/txn_insert_inject_case.groovy | 35 +-
.../analyzer/test_japanese_analyzer.groovy | 114 +
.../inverted_index_p0/test_properties.groovy | 2 +-
.../suites/mtmv_ivm_restart_p0/load.groovy | 54 +
.../suites/mtmv_ivm_restart_p0/test.groovy | 23 +-
.../suites/mtmv_p0/ivm/test_ivm_agg_1.groovy | 585 +++++
.../suites/mtmv_p0/ivm/test_ivm_agg_2.groovy | 488 ++++
.../suites/mtmv_p0/ivm/test_ivm_agg_3.groovy | 417 ++++
.../suites/mtmv_p0/ivm/test_ivm_agg_4.groovy | 430 ++++
.../suites/mtmv_p0/ivm/test_ivm_agg_5.groovy | 187 ++
.../suites/mtmv_p0/ivm/test_ivm_agg_6.groovy | 162 ++
.../suites/mtmv_p0/ivm/test_ivm_agg_join_1.groovy | 367 +++
.../suites/mtmv_p0/ivm/test_ivm_agg_join_2.groovy | 475 ++++
.../suites/mtmv_p0/ivm/test_ivm_agg_join_3.groovy | 87 +
.../mtmv_p0/ivm/test_ivm_agg_outer_join_1.groovy | 126 ++
.../mtmv_p0/ivm/test_ivm_agg_shared_columns.groovy | 249 ++
.../suites/mtmv_p0/ivm/test_ivm_basic_mtmv.groovy | 298 +++
.../mtmv_p0/ivm/test_ivm_binlog_order_1.groovy | 88 +
.../mtmv_p0/ivm/test_ivm_bitmap_agg_1.groovy | 210 ++
.../mtmv_p0/ivm/test_ivm_bitmap_agg_2.groovy | 197 ++
.../ivm/test_ivm_bitmap_runtime_fallback.groovy | 110 +
.../mtmv_p0/ivm/test_ivm_chained_mtmv_1.groovy | 113 +
.../mtmv_p0/ivm/test_ivm_chained_mtmv_2.groovy | 146 ++
.../ivm/test_ivm_complete_refresh_rowid.groovy | 94 +
.../ivm/test_ivm_create_if_not_exists.groovy | 209 ++
.../mtmv_p0/ivm/test_ivm_cross_db_same_name.groovy | 134 ++
.../ivm/test_ivm_cross_db_single_base.groovy | 77 +
.../suites/mtmv_p0/ivm/test_ivm_cube_repeat.groovy | 137 ++
.../suites/mtmv_p0/ivm/test_ivm_decimal_avg.groovy | 105 +
.../test_ivm_drop_column_fallback_reason.groovy | 110 +
...test_ivm_dup_excluded_no_binlog_fallback.groovy | 112 +
.../mtmv_p0/ivm/test_ivm_dup_keys_lsn_rowid.groovy | 277 +++
.../mtmv_p0/ivm/test_ivm_dup_keys_mtmv.groovy | 101 +
.../ivm/test_ivm_excluded_trigger_table.groovy | 172 ++
.../test_ivm_execution_failure_no_fallback.groovy | 125 +
.../mtmv_p0/ivm/test_ivm_explain_refresh.groovy | 178 ++
.../test_ivm_fallback_stream_multi_batch.groovy | 284 +++
...test_ivm_fallback_stream_multi_batch_dup.groovy | 267 +++
...test_ivm_full_outer_join_residual_update.groovy | 105 +
.../mtmv_p0/ivm/test_ivm_hidden_columns.groovy | 148 ++
.../mtmv_p0/ivm/test_ivm_inner_join_1.groovy | 477 ++++
.../mtmv_p0/ivm/test_ivm_inner_join_2.groovy | 429 ++++
.../ivm/test_ivm_inner_join_update_delete.groovy | 112 +
.../ivm/test_ivm_internal_stream_guard.groovy | 163 ++
.../ivm/test_ivm_minmax_runtime_fallback.groovy | 110 +
.../mtmv_p0/ivm/test_ivm_mtmv_row_binlog.groovy | 89 +
.../ivm/test_ivm_nested_outer_join_create.groovy | 203 ++
.../mtmv_p0/ivm/test_ivm_nullable_row_id.groovy | 155 ++
.../mtmv_p0/ivm/test_ivm_one_row_relation_1.groovy | 210 ++
.../test_ivm_one_row_relation_partitioned.groovy | 154 ++
.../mtmv_p0/ivm/test_ivm_outer_join_1.groovy | 263 +++
.../mtmv_p0/ivm/test_ivm_outer_join_2.groovy | 321 +++
.../mtmv_p0/ivm/test_ivm_outer_join_3.groovy | 178 ++
.../mtmv_p0/ivm/test_ivm_outer_join_4.groovy | 125 +
.../mtmv_p0/ivm/test_ivm_outer_join_5.groovy | 141 ++
.../mtmv_p0/ivm/test_ivm_outer_join_6.groovy | 154 ++
.../ivm/test_ivm_outer_join_union_null_side.groovy | 121 +
.../ivm/test_ivm_partition_baseline_rebuild.groovy | 96 +
.../ivm/test_ivm_partition_sync_retry.groovy | 97 +
.../ivm/test_ivm_partition_unique_key.groovy | 233 ++
.../ivm/test_ivm_partition_window_limit.groovy | 124 +
.../ivm/test_ivm_partition_window_remove.groovy | 137 ++
.../ivm/test_ivm_plan_signature_fallback.groovy | 85 +
.../mtmv_p0/ivm/test_ivm_refresh_dry_run.groovy | 87 +
.../suites/mtmv_p0/ivm/test_ivm_repeat_1.groovy | 133 ++
.../suites/mtmv_p0/ivm/test_ivm_repeat_2.groovy | 134 ++
.../mtmv_p0/ivm/test_ivm_repeat_join_1.groovy | 245 ++
.../ivm/test_ivm_replace_stream_cleanup.groovy | 118 +
.../ivm/test_ivm_replace_table_reconcile.groovy | 95 +
.../mtmv_p0/ivm/test_ivm_rewrite_projection.groovy | 79 +
.../ivm/test_ivm_sequence_delta_overwrite.groovy | 102 +
.../suites/mtmv_p0/ivm/test_ivm_snapshot.groovy | 168 ++
...t_ivm_strict_failure_partition_atomicity.groovy | 99 +
.../mtmv_p0/ivm/test_ivm_subquery_alias_1.groovy | 106 +
.../mtmv_p0/ivm/test_ivm_subquery_alias_2.groovy | 90 +
.../mtmv_p0/ivm/test_ivm_subquery_alias_3.groovy | 130 ++
.../mtmv_p0/ivm/test_ivm_task_query_id.groovy | 78 +
.../suites/mtmv_p0/ivm/test_ivm_union_1.groovy | 399 ++++
.../suites/mtmv_p0/ivm/test_ivm_union_2.groovy | 468 ++++
.../suites/mtmv_p0/ivm/test_ivm_union_3.groovy | 242 ++
.../ivm/test_ivm_union_delete_same_base.groovy | 93 +
.../mtmv_p0/ivm/test_ivm_use_full_keys_1.groovy | 263 +++
.../mtmv_p0/ivm/test_ivm_use_full_keys_2.groovy | 191 ++
.../mtmv_p0/ivm/test_ivm_use_full_keys_3.groovy | 107 +
.../mtmv_p0/ivm/test_ivm_use_full_keys_4.groovy | 117 +
.../mtmv_p0/ivm/test_ivm_use_full_keys_5.groovy | 139 ++
.../mtmv_p0/ivm/test_ivm_use_full_keys_6.groovy | 171 ++
.../mtmv_p0/ivm/test_ivm_varchar_key_rowid.groovy | 187 ++
.../test_auto_refresh_complete_method.groovy | 83 +
.../suites/mtmv_p0/test_build_mtmv.groovy | 3 +
.../test_excluded_trigger_table_mtmv.groovy | 74 +
.../suites/mtmv_p0/test_mtmv_property.groovy | 6 +-
.../test_point_query_partition_not_exists.groovy | 130 ++
.../query_p0/cache/sql_cache_object_type.groovy | 107 +
.../array_functions/test_array_except_all.groovy | 139 ++
.../map_functions/test_map_lambda.groovy | 400 ++++
.../test_ranger_hive_lowercase_access_type.groovy | 188 ++
.../test_row_binlog_flexible_partial_update.groovy | 176 ++
...nlog_flexible_partial_update_no_sequence.groovy | 101 +
.../test_binlog_property_alter_exception.groovy | 96 +
.../test_olap_table_stream_snapshot.groovy | 35 +
.../test_table_stream_alter_comment.groovy | 105 +
...ant_field_pattern_invalid_inverted_index.groovy | 2 +-
thirdparty/CHANGELOG.md | 8 +-
thirdparty/arrow-paimon-vars.sh | 666 ------
thirdparty/build-thirdparty.sh | 215 +-
thirdparty/download-thirdparty.sh | 151 +-
thirdparty/paimon-cpp-cache.cmake | 142 --
...arrow-17.0.0-force-write-int96-timestamps.patch | 98 -
thirdparty/patches/apache-arrow-17.0.0-lzo.patch | 84 -
.../patches/apache-arrow-17.0.0-paimon.patch | 224 --
...arrow-24.0.0-force-write-int96-timestamps.patch | 5 +-
.../patches/apache-arrow-24.0.0-paimon.patch | 226 --
thirdparty/patches/lance-c-0.1.7-pr-64.patch | 1522 -------------
thirdparty/patches/lance-c-0.1.8-pr-69.patch | 653 ++++++
.../paimon-cpp-arrow-24-compatibility.patch | 64 -
.../patches/paimon-cpp-arrow-24-compute.patch | 44 -
.../paimon-cpp-buildutils-static-deps.patch | 362 ---
.../patches/thrift-0.16-fix_mutex_include.patch | 9 -
.../thrift-0.16-reset-consumed-message-size.patch | 29 -
thirdparty/test/arrow-paimon-lifecycle-test.sh | 688 ------
thirdparty/test/paimon-codec-dependency-test.sh | 78 -
thirdparty/vars.sh | 51 +-
1213 files changed, 87371 insertions(+), 15855 deletions(-)
create mode 100644 .github/scripts/test_emit_litefuse_otel_io.py
create mode 100644 be/dict/kuromoji/README.md
create mode 100644 be/src/exprs/aggregate/aggregate_function_state_combine.h
create mode 100644 be/src/exprs/function/array/function_array_except_all.cpp
delete mode 100644 be/src/format/table/paimon_cpp_reader.cpp
delete mode 100644 be/src/format/table/paimon_cpp_reader.h
delete mode 100644 be/src/format/table/paimon_doris_file_system.cpp
delete mode 100644 be/src/format/table/paimon_predicate_converter.cpp
delete mode 100644 be/src/format/table/paimon_predicate_converter.h
create mode 100644 be/src/glibc-compatibility/lance_symbol_versions.c
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/KuromojiAnalyzer.h
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/KuromojiMode.h
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/KuromojiTokenizer.cpp
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/KuromojiTokenizer.h
create mode 100644 be/src/storage/index/inverted/analyzer/kuromoji/dict/darts.h
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/dict/kuromoji_dict_format.h
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/dict/kuromoji_dictionary.cpp
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/dict/kuromoji_dictionary.h
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/dict/kuromoji_dictionary_builder.cpp
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/dict/kuromoji_dictionary_builder.h
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/dict/kuromoji_ipadic_parser.cpp
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/dict/kuromoji_ipadic_parser.h
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/kuromoji_normalize.h
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/kuromoji_viterbi.cpp
create mode 100644
be/src/storage/index/inverted/analyzer/kuromoji/kuromoji_viterbi.h
create mode 100644 be/src/tools/kuromoji_build_dict.cpp
create mode 100644 be/test/exprs/aggregate/agg_state_combine_test.cpp
create mode 100644 be/test/exprs/function/function_array_except_all_test.cpp
delete mode 100644 be/test/format/table/paimon_cpp_reader_test.cpp
delete mode 100644 be/test/format/table/paimon_doris_file_system_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji/darts_smoke_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji/kuromoji_dict_format_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji/kuromoji_dictionary_builder_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji/kuromoji_dictionary_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji/kuromoji_ipadic_parser_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji/kuromoji_normalize_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji/kuromoji_real_dict_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji/kuromoji_viterbi_test.cpp
create mode 100644
be/test/storage/index/inverted/analyzer/kuromoji_analyzer_test.cpp
copy be/{src/format/table/paimon_doris_file_system.h =>
test/storage/index/inverted/analyzer/kuromoji_tokenizer_test.cpp} (58%)
copy be/{src/format/table/paimon_doris_file_system.h =>
test/storage/index/inverted/kuromoji_parser_type_test.cpp} (53%)
create mode 100644 be/test/storage/iterator/vertical_block_reader_test.cpp
create mode 100644 be/test/testutil/container_credentials_endpoint.h
create mode 100644 cloud/test/fdb_getentropy_compat.c
create mode 100644 common/cpp/test/container_credentials_test_util.h
create mode 100644 dist/licenses/LICENSE-darts-clone.txt
create mode 100644 dist/licenses/LICENSE-ipadic.txt
delete mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/CacheFactory.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/CatalogMetaCache.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/MetaCache.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/MetaCacheDefinition.java
delete mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/MetaCacheEntry.java
delete mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/MetaCacheEntryStats.java
copy fe/{fe-core/src/main/java/org/apache/doris/statistics/AnalysisState.java
=>
fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/MetaCacheRemovalListener.java}
(73%)
copy fe/{fe-core/src/main/java/org/apache/doris/mtmv/MTMVAlterOpType.java =>
fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/MetaCacheRemovalReason.java}
(79%)
create mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/ScopePath.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/ScopedMetaCache.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/ScopedMetaCacheRegistry.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/main/java/org/apache/doris/connector/cache/StripedPhaseGate.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/test/java/org/apache/doris/connector/cache/CatalogMetaCacheTest.java
delete mode 100644
fe/fe-connector/fe-connector-cache/src/test/java/org/apache/doris/connector/cache/MetaCacheEntryTest.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/test/java/org/apache/doris/connector/cache/ScopePathTest.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/test/java/org/apache/doris/connector/cache/ScopedMetaCacheConcurrencyTest.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/test/java/org/apache/doris/connector/cache/ScopedMetaCacheHierarchyTest.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/test/java/org/apache/doris/connector/cache/ScopedMetaCacheLeakTest.java
create mode 100644
fe/fe-connector/fe-connector-cache/src/test/java/org/apache/doris/connector/cache/StripedPhaseGateTest.java
copy fe/fe-core/src/main/java/org/apache/doris/{statistics/JobPriority.java =>
clone/RowBinlogRepairReason.java} (85%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/clone/RowBinlogTabletLocality.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/metacache/CacheSpec.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/metacache/CatalogEntryGroup.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/metacache/CatalogMetaCacheRuntime.java
rename
fe/fe-core/src/main/java/org/apache/doris/datasource/metacache/{AbstractExternalMetaCache.java
=> ExternalCatalogMetaCache.java} (76%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/metacache/ExternalMetaCacheRegistry.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/metacache/ExternalMetaCacheRouteResolver.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/metacache/FeMetaCacheEntry.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/metacache/MetaCacheEntry.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/response/SchemaTypeDesc.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/AGENTS.md
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmAggDeltaHandler.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmDeltaRewriteHelper.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmDeltaRewriteResult.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmDeltaRewriteState.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmDeltaRewriteVisitor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmDeltaRewriter.java
copy
fe/fe-core/src/main/java/org/apache/doris/{statistics/SlotStatsDeriveResult.java
=> mtmv/ivm/IvmDryRunLimit.java} (54%)
copy
fe/fe-core/src/main/java/org/apache/doris/{statistics/AnalyzeSkipException.java
=> mtmv/ivm/IvmException.java} (53%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmFailureClassifier.java
copy
fe/fe-core/src/main/java/org/apache/doris/{statistics/AnalyzeSkipException.java
=> mtmv/ivm/IvmFailureReason.java} (52%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmIncrRefreshContext.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmIncrRefreshManager.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmIncrRefreshResult.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmJoinDeltaHandler.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmLinearDeltaHandler.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmPlanSignature.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmPlanSignatureGenerator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmRewriteContext.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmRewriteResult.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmSequenceCalculator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/IvmUtil.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggApplyContext.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggAvgProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggBitmapProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggBitmapUnionCountProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggBitmapUnionProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggColumnKey.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggCountProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggDeltaSlotRef.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggExpressionBuilder.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggExtremalProcessor.java
copy fe/fe-core/src/main/java/org/apache/doris/{statistics/ExprStats.java =>
mtmv/ivm/agg/IvmAggFunctionKind.java} (66%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggFunctionProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggFunctionRegistry.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggMaxProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggMeta.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggMinProcessor.java
copy fe/fe-core/src/main/java/org/apache/doris/{statistics/JobPriority.java =>
mtmv/ivm/agg/IvmAggStateKey.java} (83%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggSumLikeProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggSumProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggTarget.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/ivm/agg/IvmAggTargetSpec.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/IvmFullRefreshMTMV.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/IvmIncrRefreshMTMV.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/IvmNormalizeMTMV.java
rename be/src/format/table/paimon_doris_file_system.h =>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/LambdaBinding.java
(62%)
copy fe/fe-core/src/main/java/org/apache/doris/{statistics/HistData.java =>
nereids/trees/expressions/functions/LambdaBindingSpec.java} (65%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/LambdaBindingSpecs.java
copy fe/fe-core/src/main/java/org/apache/doris/{mtmv/MTMVAlterOpType.java =>
nereids/trees/expressions/functions/agg/NotSupportAggState.java} (81%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/combinator/{StateCombinator.java
=> CombineCombinator.java} (58%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{MurmurHash364.java
=> ArrayExceptAll.java} (50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MapAll.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MapApply.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MapExists.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MapFilter.java
copy
fe/fe-core/src/main/java/org/apache/doris/{statistics/SlotStatsDeriveResult.java
=> nereids/trees/expressions/functions/scalar/MapFromEntriesUnique.java} (52%)
copy fe/fe-core/src/main/java/org/apache/doris/{mtmv/MTMVAnalyzeQueryInfo.java
=>
nereids/trees/expressions/functions/scalar/MapFromFilteredEntriesUnique.java}
(51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MapLambdaFunctionUtils.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/TransformKeys.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/TransformValues.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AlterStreamCommand.java
copy
fe/fe-core/src/main/java/org/apache/doris/{statistics/AnalyzeSkipException.java
=> nereids/trees/plans/commands/insert/CancelableCommand.java} (51%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisInfo.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisInfoBuilder.java (96%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisJob.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisManager.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisState.java (95%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisTaskExecutor.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisTaskWrapper.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AnalyzeSkipException.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/AutoAnalysisPendingJob.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/BaseAnalysisTask.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/ColStatsMeta.java (90%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/ExternalAnalysisTask.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/FollowerColumnSender.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/HistogramTask.java (95%)
copy fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/JobPriority.java (95%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/NewPartitionLoadedEvent.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/OlapAnalysisTask.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/PluginDrivenSampleAnalysisTask.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/QueryColumn.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/StatisticsAutoCollector.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/StatisticsJobAppender.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/StatisticsMetricCollector.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/StatsCategory.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/StatsGranularity.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/TableStatsMeta.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/TaskStatusWrapper.java (96%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
analysis}/UpdateRowsEvent.java (98%)
copy fe/fe-core/src/main/java/org/apache/doris/statistics/{JobPriority.java =>
analysis/package-info.java} (86%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/BasicAsyncCacheLoader.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/ColumnStatisticsCacheLoader.java (92%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/HistogramCacheLoader.java (92%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/InvalidateStatsTarget.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/PartitionColumnStatisticCacheKey.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/PartitionColumnStatisticCacheLoader.java (92%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/StatisticsCache.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/StatisticsCacheKey.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
cache}/UpdatePartitionStatsTarget.java (97%)
copy fe/fe-core/src/main/java/org/apache/doris/statistics/{JobPriority.java =>
cache/package-info.java} (86%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/Bucket.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/ColumnStatistic.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/ColumnStatisticBuilder.java (99%)
copy fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/ExprStats.java (96%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/Histogram.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/HistogramBuilder.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/PartitionColumnStatistic.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/PartitionColumnStatisticBuilder.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/SlotStatsDeriveResult.java (96%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/StatisticRange.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/Statistics.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/StatisticsBuilder.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/StatsDeriveResult.java (99%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
model}/StatsType.java (97%)
copy fe/fe-core/src/main/java/org/apache/doris/statistics/{JobPriority.java =>
model/package-info.java} (84%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ExprStats.java =>
package-info.java} (76%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
repository}/ColStatsData.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
repository}/HistData.java (96%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
repository}/ResultRow.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
repository}/StatisticsCleaner.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
repository}/StatisticsRepository.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{ =>
repository}/StatsId.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/statistics/{JobPriority.java
=> repository/package-info.java} (85%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/alter/CloudSchemaChangeJobV2Test.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/InvertedIndexKuromojiValidationTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/AlterTableStreamCommentTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/ShowCreateMTMVTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/authorizer/ranger/hive/RangerHiveAccessControllerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/clone/RowBinlogRebalancerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/clone/RowBinlogTabletLocalityTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/clone/RowBinlogTabletSchedulerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/datasource/CloudInternalCatalogTest.java
rename
fe/fe-core/src/test/java/org/apache/doris/datasource/metacache/{AbstractExternalMetaCacheTest.java
=> ExternalCatalogMetaCacheTest.java} (89%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/metacache/FeMetaCacheEntryTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/metacache/MetaCacheEntryTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/httpv2/rest/TableSchemaActionColumnInfoTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/httpv2/rest/response/SchemaTypeDescTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/extensions/mtmv/MTMVTaskContextCompatTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/master/RowBinlogReportHandlerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVPropertyUtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmAggDeltaHandlerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmBaselineRebuildTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmDeltaRewriteHelperTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmDeltaRewriteStateTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmDeltaRewriterTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmDeltaTestBase.java
copy
fe/fe-core/src/{main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalPlan.java
=> test/java/org/apache/doris/mtmv/ivm/IvmFailureReasonTest.java} (54%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmIncrRefreshManagerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmInfoTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmJoinDeltaHandlerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmLinearDeltaHandlerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmNormalizeMTMVJoinTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmNormalizeMTMVUnionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmPlanSignatureGeneratorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmRewriteContextTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmSequenceCalculatorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/IvmUtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggAvgProcessorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggBitmapUnionCountProcessorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggBitmapUnionProcessorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggColumnSharingTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggCountProcessorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggMaxProcessorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggMinProcessorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggProcessorTestBase.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/ivm/agg/IvmAggSumProcessorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/parser/LeanTokenModeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/parser/PrimaryExpressionAstTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/parser/QueryOrDmlCommonPrefixPlanTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/parser/QueryOrganizationPlanTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/IvmFullRefreshMTMVTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/IvmIncrRefreshMTMVTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/IvmNormalizeMTMVTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/AccessPathExpressionCollectorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/combinator/CombineCombinatorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MapLambdaFunctionsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/udf/UdfBuilderArityTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/CreateMTMVCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/ExplainRefreshMTMVCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/RefreshMTMVCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/info/ModifyPartitionOpTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/info/RefreshMTMVInfoAnalyzeTest.java
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisJobTest.java (98%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisManagerTest.java (99%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisTaskExecutorTest.java (96%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/AnalysisTaskWrapperTest.java (96%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/AnalyzeTest.java (95%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/BaseAnalysisTaskTest.java (95%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/FollowerColumnSenderTest.java (99%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/HistogramTaskTest.java (95%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/MVStatisticsTest.java (96%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/OlapAnalysisTaskTest.java (99%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/StatisticsAutoCollectorTest.java (99%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/StatisticsJobAppenderTest.java (99%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
analysis}/TableStatsMetaTest.java (98%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
cache}/CacheTest.java (97%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
cache}/StatisticsCacheTest.java (97%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
model}/HistogramTest.java (99%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
model}/StatisticsTest.java (98%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
repository}/ColStatsDataTest.java (98%)
rename fe/fe-core/src/test/java/org/apache/doris/statistics/{ =>
repository}/StatisticsCleanerTest.java (92%)
create mode 100644
fe/fe-sql-parser-benchmark/src/main/java/org/apache/doris/sqlparser/benchmark/IdentifierPostProcessorBenchmark.java
create mode 100644
fe/fe-sql-parser-benchmark/src/main/java/org/apache/doris/sqlparser/benchmark/LeanTokenModeBenchmark.java
create mode 100644
fe/fe-sql-parser-benchmark/src/main/java/org/apache/doris/sqlparser/benchmark/LocalRulePrefixBenchmark.java
create mode 100644
fe/fe-sql-parser-benchmark/src/main/java/org/apache/doris/sqlparser/benchmark/PrimaryExpressionBenchmark.java
create mode 100644
fe/fe-sql-parser-benchmark/src/main/java/org/apache/doris/sqlparser/benchmark/QueryOrDmlCommonPrefixBenchmark.java
create mode 100644
fe/fe-sql-parser-benchmark/src/main/java/org/apache/doris/sqlparser/benchmark/QueryOrganizationBenchmark.java
delete mode 100644
fe/fe-sql-parser/src/main/java/org/apache/doris/nereids/parser/PostProcessor.java
create mode 100644
fe/fe-sql-parser/src/test/java/org/apache/doris/sqlparser/DorisLexerLeanTokenModeTest.java
create mode 100644
fe/fe-sql-parser/src/test/java/org/apache/doris/sqlparser/LimitClausePrefixTest.java
create mode 100644
fe/fe-sql-parser/src/test/java/org/apache/doris/sqlparser/PrimaryExpressionTest.java
create mode 100644
fe/fe-sql-parser/src/test/java/org/apache/doris/sqlparser/QueryOrDmlCommonPrefixTest.java
create mode 100644
fe/fe-sql-parser/src/test/java/org/apache/doris/sqlparser/QueryOrganizationBehaviorTest.java
create mode 100644
fe/fe-sql-parser/src/test/java/org/apache/doris/sqlparser/StatementBaseDispatchTest.java
create mode 100644 regression-test/data/mtmv_ivm_restart_p0/test.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_1.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_2.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_3.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_4.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_5.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_6.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_join_1.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_join_2.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_agg_join_3.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_agg_outer_join_1.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_agg_shared_columns.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_basic_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_bitmap_agg_1.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_bitmap_agg_2.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_bitmap_runtime_fallback.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_chained_mtmv_1.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_chained_mtmv_2.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_create_if_not_exists.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_cross_db_same_name.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_cross_db_single_base.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_cube_repeat.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_decimal_avg.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_drop_column_fallback_reason.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_dup_excluded_no_binlog_fallback.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_dup_keys_lsn_rowid.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_dup_keys_mtmv.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_excluded_trigger_table.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_execution_failure_no_fallback.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_explain_refresh.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_full_outer_join_residual_update.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_hidden_columns.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_inner_join_1.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_inner_join_2.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_inner_join_update_delete.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_minmax_runtime_fallback.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_mtmv_row_binlog.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_nested_outer_join_create.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_nullable_row_id.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_one_row_relation_1.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_one_row_relation_partitioned.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_outer_join_1.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_outer_join_2.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_outer_join_3.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_outer_join_4.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_outer_join_5.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_outer_join_6.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_outer_join_union_null_side.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_partition_baseline_rebuild.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_partition_sync_retry.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_partition_unique_key.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_partition_window_limit.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_partition_window_remove.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_plan_signature_fallback.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_refresh_dry_run.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_repeat_1.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_repeat_2.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_repeat_join_1.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_replace_stream_cleanup.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_replace_table_reconcile.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_rewrite_projection.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_sequence_delta_overwrite.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_snapshot.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_strict_failure_partition_atomicity.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_subquery_alias_1.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_subquery_alias_2.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_subquery_alias_3.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_union_1.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_union_2.out
create mode 100644 regression-test/data/mtmv_p0/ivm/test_ivm_union_3.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_union_delete_same_base.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_use_full_keys_1.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_use_full_keys_2.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_use_full_keys_3.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_use_full_keys_4.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_use_full_keys_5.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_use_full_keys_6.out
create mode 100644
regression-test/data/mtmv_p0/ivm/test_ivm_varchar_key_rowid.out
create mode 100644
regression-test/data/mtmv_p0/test_auto_refresh_complete_method.out
create mode 100644
regression-test/data/point_query_p0/test_point_query_partition_not_exists.out
create mode 100644
regression-test/data/query_p0/sql_functions/array_functions/test_array_except_all.out
create mode 100644
regression-test/data/query_p0/sql_functions/map_functions/test_map_lambda.out
create mode 100644
regression-test/data/ranger_p2/test_ranger_hive_lowercase_access_type.out
create mode 100644
regression-test/data/row_binlog_p0/test_row_binlog_flexible_partial_update.out
create mode 100644
regression-test/data/row_binlog_p0/test_row_binlog_flexible_partial_update_no_sequence.out
create mode 100644
regression-test/data/table_stream_p0/test_table_stream_alter_comment.out
create mode 100644
regression-test/suites/arrow_flight_sql_p0/test_point_query_over_arrow_flight.groovy
create mode 100644
regression-test/suites/arrow_flight_sql_p0/test_sql_cache_over_arrow_flight.groovy
create mode 100644
regression-test/suites/auth_p0/test_mysql_user_visibility.groovy
create mode 100644
regression-test/suites/cloud_p0/compaction/test_cloud_single_rowset_grouped_compaction.groovy
create mode 100644
regression-test/suites/cloud_p0/test_partition_cloud_add_build_index_validation.groovy
create mode 100644
regression-test/suites/cloud_p0/test_partition_cloud_inverted_index_format.groovy
create mode 100644
regression-test/suites/cloud_p0/test_partition_cloud_inverted_index_storage_format_meta_write_switch.groovy
create mode 100644
regression-test/suites/cloud_p0/test_partition_cloud_inverted_index_storage_format_recycle_truncate.groovy
create mode 100644
regression-test/suites/cloud_p0/test_partition_cloud_inverted_index_storage_format_rollout.groovy
create mode 100644
regression-test/suites/cloud_p0/test_partition_cloud_inverted_index_storage_format_rowset_schema.groovy
create mode 100644
regression-test/suites/cloud_p0/test_partition_cloud_inverted_index_storage_format_stream_load.groovy
rename
regression-test/suites/external_table_p0/paimon/{test_paimon_cpp_reader.groovy
=> test_paimon_reader_parity.groovy} (81%)
create mode 100644
regression-test/suites/inverted_index_p0/analyzer/test_japanese_analyzer.groovy
create mode 100644 regression-test/suites/mtmv_ivm_restart_p0/load.groovy
copy
fe/fe-core/src/main/java/org/apache/doris/catalog/RecyclePartitionParam.java =>
regression-test/suites/mtmv_ivm_restart_p0/test.groovy (59%)
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_agg_1.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_agg_2.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_agg_3.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_agg_4.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_agg_5.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_agg_6.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_agg_join_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_agg_join_2.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_agg_join_3.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_agg_outer_join_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_agg_shared_columns.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_basic_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_binlog_order_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_bitmap_agg_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_bitmap_agg_2.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_bitmap_runtime_fallback.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_chained_mtmv_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_chained_mtmv_2.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_complete_refresh_rowid.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_create_if_not_exists.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_cross_db_same_name.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_cross_db_single_base.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_cube_repeat.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_decimal_avg.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_drop_column_fallback_reason.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_dup_excluded_no_binlog_fallback.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_dup_keys_lsn_rowid.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_dup_keys_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_excluded_trigger_table.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_execution_failure_no_fallback.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_explain_refresh.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_fallback_stream_multi_batch.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_fallback_stream_multi_batch_dup.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_full_outer_join_residual_update.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_hidden_columns.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_inner_join_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_inner_join_2.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_inner_join_update_delete.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_internal_stream_guard.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_minmax_runtime_fallback.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_mtmv_row_binlog.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_nested_outer_join_create.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_nullable_row_id.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_one_row_relation_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_one_row_relation_partitioned.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_outer_join_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_outer_join_2.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_outer_join_3.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_outer_join_4.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_outer_join_5.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_outer_join_6.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_outer_join_union_null_side.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_partition_baseline_rebuild.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_partition_sync_retry.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_partition_unique_key.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_partition_window_limit.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_partition_window_remove.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_plan_signature_fallback.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_refresh_dry_run.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_repeat_1.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_repeat_2.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_repeat_join_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_replace_stream_cleanup.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_replace_table_reconcile.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_rewrite_projection.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_sequence_delta_overwrite.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_snapshot.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_strict_failure_partition_atomicity.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_subquery_alias_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_subquery_alias_2.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_subquery_alias_3.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_task_query_id.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_union_1.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_union_2.groovy
create mode 100644 regression-test/suites/mtmv_p0/ivm/test_ivm_union_3.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_union_delete_same_base.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_use_full_keys_1.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_use_full_keys_2.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_use_full_keys_3.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_use_full_keys_4.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_use_full_keys_5.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_use_full_keys_6.groovy
create mode 100644
regression-test/suites/mtmv_p0/ivm/test_ivm_varchar_key_rowid.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_auto_refresh_complete_method.groovy
create mode 100644
regression-test/suites/point_query_p0/test_point_query_partition_not_exists.groovy
create mode 100644
regression-test/suites/query_p0/cache/sql_cache_object_type.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/array_functions/test_array_except_all.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/map_functions/test_map_lambda.groovy
create mode 100644
regression-test/suites/ranger_p2/test_ranger_hive_lowercase_access_type.groovy
create mode 100644
regression-test/suites/row_binlog_p0/test_row_binlog_flexible_partial_update.groovy
create mode 100644
regression-test/suites/row_binlog_p0/test_row_binlog_flexible_partial_update_no_sequence.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_binlog_property_alter_exception.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_table_stream_alter_comment.groovy
delete mode 100644 thirdparty/arrow-paimon-vars.sh
delete mode 100644 thirdparty/paimon-cpp-cache.cmake
delete mode 100644
thirdparty/patches/apache-arrow-17.0.0-force-write-int96-timestamps.patch
delete mode 100644 thirdparty/patches/apache-arrow-17.0.0-lzo.patch
delete mode 100644 thirdparty/patches/apache-arrow-17.0.0-paimon.patch
delete mode 100644 thirdparty/patches/apache-arrow-24.0.0-paimon.patch
delete mode 100644 thirdparty/patches/lance-c-0.1.7-pr-64.patch
create mode 100644 thirdparty/patches/lance-c-0.1.8-pr-69.patch
delete mode 100644 thirdparty/patches/paimon-cpp-arrow-24-compatibility.patch
delete mode 100644 thirdparty/patches/paimon-cpp-arrow-24-compute.patch
delete mode 100644 thirdparty/patches/paimon-cpp-buildutils-static-deps.patch
delete mode 100644 thirdparty/patches/thrift-0.16-fix_mutex_include.patch
delete mode 100644
thirdparty/patches/thrift-0.16-reset-consumed-message-size.patch
delete mode 100755 thirdparty/test/arrow-paimon-lifecycle-test.sh
delete mode 100755 thirdparty/test/paimon-codec-dependency-test.sh
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
