This is an automated email from the ASF dual-hosted git repository.
mrhhsg pushed a change to branch spill_repartition
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 0258bea5c27 repartitioner
add 5fd3dc93c92 [be](ubsan) fix rowcusor ubsan error (#61153)
add 4d85ff1c8e5 [be](namespace) remove vecotorized and pipeline namespace
(#61142)
add 8b03038f5d2 [fix](test) fix death tests crash in multi-threaded UT
binary (#61158)
add 7263f1e91b9 [chore](config) Add `request_timeout` config for aws
client configuration (#60906)
add 8fe520a9836 [fix](group commit) forbid set group_commit_interval_ms
and group_commit_data_bytes to 0 (#61034)
add 92c779ee4ab [fix](recycler) use document_remove to delete versioned
rowset meta (#61157)
add 926d0dc9e04 repartitioner
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 (0258bea5c27)
\
N -- N -- N refs/heads/spill_repartition (926d0dc9e04)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
be/benchmark/benchmark_fastunion.hpp | 20 +-
be/benchmark/benchmark_main.cpp | 4 +-
be/benchmark/benchmark_string.hpp | 4 +-
be/src/cloud/cloud_delta_writer.cpp | 3 +-
be/src/cloud/cloud_delta_writer.h | 2 +-
be/src/common/config.cpp | 1 +
be/src/common/config.h | 1 +
be/src/common/kerberos/kerberos_ticket_mgr.cpp | 3 +-
be/src/common/kerberos/kerberos_ticket_mgr.h | 4 +-
be/src/common/stack_trace.cpp | 2 +-
be/src/common/symbol_index.cpp | 4 +-
be/src/core/accurate_comparison.h | 4 +-
be/src/core/arena.h | 4 +-
be/src/core/arena_with_free_lists.h | 4 +-
be/src/core/block/block.cpp | 6 +-
be/src/core/block/block.h | 3 -
be/src/core/block/column_numbers.h | 2 +-
be/src/core/block/column_with_type_and_name.cpp | 8 +-
be/src/core/block/column_with_type_and_name.h | 7 +-
be/src/core/block/columns_with_type_and_name.h | 4 +-
be/src/core/block/materialize_block.cpp | 4 +-
be/src/core/block/materialize_block.h | 4 +-
be/src/core/call_on_type_index.h | 4 +-
be/src/core/column/column.cpp | 4 +-
be/src/core/column/column.h | 8 +-
be/src/core/column/column_array.cpp | 4 +-
be/src/core/column/column_array.h | 4 +-
be/src/core/column/column_complex.h | 4 +-
be/src/core/column/column_const.cpp | 4 +-
be/src/core/column/column_const.h | 4 +-
be/src/core/column/column_decimal.cpp | 6 +-
be/src/core/column/column_decimal.h | 4 +-
be/src/core/column/column_dictionary.h | 15 +-
be/src/core/column/column_dummy.h | 4 +-
be/src/core/column/column_execute_util.h | 4 +-
be/src/core/column/column_filter_helper.cpp | 8 +-
be/src/core/column/column_filter_helper.h | 4 +-
be/src/core/column/column_fixed_length_object.h | 4 +-
be/src/core/column/column_map.cpp | 4 +-
be/src/core/column/column_map.h | 4 +-
be/src/core/column/column_nothing.h | 4 +-
be/src/core/column/column_nullable.cpp | 8 +-
be/src/core/column/column_nullable.h | 4 +-
be/src/core/column/column_string.cpp | 8 +-
be/src/core/column/column_string.h | 4 +-
be/src/core/column/column_struct.cpp | 6 +-
be/src/core/column/column_struct.h | 4 +-
be/src/core/column/column_varbinary.cpp | 10 +-
be/src/core/column/column_varbinary.h | 4 +-
be/src/core/column/column_variant.cpp | 29 +-
be/src/core/column/column_variant.h | 13 +-
be/src/core/column/column_vector.cpp | 4 +-
be/src/core/column/column_vector.h | 12 +-
be/src/core/column/columns_common.cpp | 4 +-
be/src/core/column/columns_common.h | 4 +-
be/src/core/column/predicate_column.h | 4 +-
be/src/core/column/subcolumn_tree.h | 6 +-
be/src/core/cow.h | 9 +-
be/src/core/data_type/convert_field_to_type.cpp | 4 +-
be/src/core/data_type/convert_field_to_type.h | 4 +-
be/src/core/data_type/data_type.cpp | 10 +-
be/src/core/data_type/data_type.h | 2 -
be/src/core/data_type/data_type_agg_state.h | 4 +-
be/src/core/data_type/data_type_array.cpp | 4 +-
be/src/core/data_type/data_type_array.h | 6 +-
be/src/core/data_type/data_type_bitmap.cpp | 4 +-
be/src/core/data_type/data_type_bitmap.h | 4 +-
be/src/core/data_type/data_type_date.cpp | 4 +-
be/src/core/data_type/data_type_date.h | 4 +-
.../data_type/data_type_date_or_datetime_v2.cpp | 6 +-
.../core/data_type/data_type_date_or_datetime_v2.h | 6 +-
be/src/core/data_type/data_type_date_time.cpp | 4 +-
be/src/core/data_type/data_type_date_time.h | 4 +-
be/src/core/data_type/data_type_decimal.cpp | 4 +-
be/src/core/data_type/data_type_decimal.h | 6 +-
be/src/core/data_type/data_type_factory.cpp | 158 +++---
be/src/core/data_type/data_type_factory.hpp | 11 +-
.../data_type/data_type_fixed_length_object.cpp | 4 +-
.../core/data_type/data_type_fixed_length_object.h | 4 +-
be/src/core/data_type/data_type_hll.cpp | 4 +-
be/src/core/data_type/data_type_hll.h | 4 +-
be/src/core/data_type/data_type_ipv4.cpp | 4 +-
be/src/core/data_type/data_type_ipv4.h | 6 +-
be/src/core/data_type/data_type_ipv6.cpp | 4 +-
be/src/core/data_type/data_type_ipv6.h | 6 +-
be/src/core/data_type/data_type_jsonb.cpp | 6 +-
be/src/core/data_type/data_type_jsonb.h | 4 +-
be/src/core/data_type/data_type_map.cpp | 4 +-
be/src/core/data_type/data_type_map.h | 6 +-
be/src/core/data_type/data_type_nothing.cpp | 4 +-
be/src/core/data_type/data_type_nothing.h | 4 +-
be/src/core/data_type/data_type_nullable.cpp | 4 +-
be/src/core/data_type/data_type_nullable.h | 6 +-
be/src/core/data_type/data_type_number.h | 4 +-
be/src/core/data_type/data_type_number_base.cpp | 4 +-
be/src/core/data_type/data_type_number_base.h | 4 +-
be/src/core/data_type/data_type_quantilestate.cpp | 4 +-
be/src/core/data_type/data_type_quantilestate.h | 4 +-
be/src/core/data_type/data_type_string.cpp | 4 +-
be/src/core/data_type/data_type_string.h | 4 +-
be/src/core/data_type/data_type_struct.cpp | 4 +-
be/src/core/data_type/data_type_struct.h | 6 +-
be/src/core/data_type/data_type_time.cpp | 4 +-
be/src/core/data_type/data_type_time.h | 4 +-
be/src/core/data_type/data_type_timestamptz.cpp | 4 +-
be/src/core/data_type/data_type_timestamptz.h | 4 +-
be/src/core/data_type/data_type_varbinary.cpp | 4 +-
be/src/core/data_type/data_type_varbinary.h | 4 +-
be/src/core/data_type/data_type_variant.cpp | 6 +-
be/src/core/data_type/data_type_variant.h | 6 +-
be/src/core/data_type/get_least_supertype.cpp | 4 +-
be/src/core/data_type/get_least_supertype.h | 4 +-
be/src/core/data_type/nested_utils.cpp | 4 +-
be/src/core/data_type/nested_utils.h | 4 +-
be/src/core/data_type/number_traits.h | 4 +-
be/src/core/data_type/primitive_type.h | 192 ++++---
.../complex_type_deserialize_util.h | 4 +-
.../core/data_type_serde/data_type_array_serde.cpp | 6 +-
.../core/data_type_serde/data_type_array_serde.h | 4 +-
.../data_type_serde/data_type_bitmap_serde.cpp | 5 +-
.../core/data_type_serde/data_type_bitmap_serde.h | 4 +-
.../data_type_date_or_datetime_serde.cpp | 9 +-
.../data_type_date_or_datetime_serde.h | 8 +-
.../data_type_serde/data_type_datetimev2_serde.cpp | 9 +-
.../data_type_serde/data_type_datetimev2_serde.h | 8 +-
.../data_type_serde/data_type_datev2_serde.cpp | 9 +-
.../core/data_type_serde/data_type_datev2_serde.h | 8 +-
.../data_type_serde/data_type_decimal_serde.cpp | 12 +-
.../core/data_type_serde/data_type_decimal_serde.h | 6 +-
.../core/data_type_serde/data_type_hll_serde.cpp | 4 +-
be/src/core/data_type_serde/data_type_hll_serde.h | 4 +-
.../core/data_type_serde/data_type_ipv4_serde.cpp | 6 +-
be/src/core/data_type_serde/data_type_ipv4_serde.h | 6 +-
.../core/data_type_serde/data_type_ipv6_serde.cpp | 8 +-
be/src/core/data_type_serde/data_type_ipv6_serde.h | 6 +-
.../core/data_type_serde/data_type_jsonb_serde.cpp | 4 +-
.../core/data_type_serde/data_type_jsonb_serde.h | 4 +-
.../core/data_type_serde/data_type_map_serde.cpp | 4 +-
be/src/core/data_type_serde/data_type_map_serde.h | 4 +-
.../core/data_type_serde/data_type_nothing_serde.h | 4 +-
.../data_type_serde/data_type_nullable_serde.cpp | 9 +-
.../data_type_serde/data_type_nullable_serde.h | 6 +-
.../data_type_serde/data_type_number_serde.cpp | 9 +-
.../core/data_type_serde/data_type_number_serde.h | 6 +-
.../data_type_quantilestate_serde.cpp | 4 +-
.../data_type_quantilestate_serde.h | 4 +-
be/src/core/data_type_serde/data_type_serde.cpp | 4 +-
be/src/core/data_type_serde/data_type_serde.h | 6 +-
.../data_type_serde/data_type_string_serde.cpp | 9 +-
.../core/data_type_serde/data_type_string_serde.h | 6 +-
.../data_type_serde/data_type_struct_serde.cpp | 5 +-
.../core/data_type_serde/data_type_struct_serde.h | 4 +-
.../core/data_type_serde/data_type_time_serde.cpp | 4 +-
be/src/core/data_type_serde/data_type_time_serde.h | 2 -
.../data_type_timestamptz_serde.cpp | 9 +-
.../data_type_serde/data_type_timestamptz_serde.h | 8 +-
.../data_type_serde/data_type_varbinary_serde.cpp | 7 +-
.../data_type_serde/data_type_varbinary_serde.h | 4 +-
.../data_type_serde/data_type_variant_serde.cpp | 8 +-
.../core/data_type_serde/data_type_variant_serde.h | 4 +-
.../core/data_type_serde/datelike_serde_common.hpp | 4 +-
be/src/core/decimal_comparison.h | 4 +-
be/src/core/field.cpp | 4 +-
be/src/core/field.h | 10 +-
be/src/core/memcmp_small.h | 16 +-
be/src/core/memcpy_small.h | 6 +-
be/src/core/pod_array.cpp | 4 +-
be/src/core/pod_array.h | 4 +-
be/src/core/pod_array_fwd.h | 4 +-
be/src/core/string_buffer.hpp | 4 +-
be/src/core/string_ref.h | 18 +-
be/src/core/type_limit.h | 30 +-
be/src/core/types.h | 43 +-
be/src/core/uint128.h | 8 +-
be/src/core/value/bitmap_value.h | 2 +-
be/src/core/value/hll.cpp | 2 +-
be/src/core/value/hll.h | 2 +-
be/src/core/value/ip_address_cidr.h | 25 +-
be/src/core/value/ipv4_value.h | 12 +-
be/src/core/value/ipv6_value.h | 10 +-
be/src/core/value/timestamptz_value.cpp | 10 +-
be/src/core/value/timestamptz_value.h | 4 +-
be/src/core/value/vdatetime_value.cpp | 39 +-
be/src/core/value/vdatetime_value.h | 10 +-
be/src/exec/common/agg_utils.h | 149 ++---
.../exec/common/arrow_column_to_doris_column.cpp | 4 +-
be/src/exec/common/arrow_column_to_doris_column.h | 4 +-
be/src/exec/common/bit_helpers.h | 4 +-
be/src/exec/common/columns_hashing.h | 4 +-
be/src/exec/common/columns_hashing_impl.h | 4 +-
.../data_gen_functions/vdata_gen_function_inf.h | 6 +-
.../common/data_gen_functions/vnumbers_tvf.cpp | 16 +-
.../exec/common/data_gen_functions/vnumbers_tvf.h | 5 +-
be/src/exec/common/distinct_agg_utils.h | 128 ++---
be/src/exec/common/field_visitors.h | 4 +-
be/src/exec/common/format_ip.cpp | 4 +-
be/src/exec/common/format_ip.h | 4 +-
be/src/exec/common/hash_table/hash.h | 94 +--
be/src/exec/common/hash_table/hash_key_type.h | 19 +-
be/src/exec/common/hash_table/hash_map_context.h | 4 +-
be/src/exec/common/hash_table/hash_map_util.h | 7 +-
be/src/exec/common/hash_table/hash_table.h | 30 +-
.../exec/common/hash_table/hash_table_set_build.h | 4 +-
.../exec/common/hash_table/hash_table_set_probe.h | 4 +-
be/src/exec/common/hash_table/join_hash_table.h | 3 +-
be/src/exec/common/hash_table/ph_hash_map.h | 2 +-
be/src/exec/common/hash_table/ph_hash_set.h | 2 +-
be/src/exec/common/hash_table/phmap_fwd_decl.h | 4 +-
be/src/exec/common/hash_table/string_hash_table.h | 8 +-
be/src/exec/common/hex.cpp | 4 +-
be/src/exec/common/hex.h | 4 +-
be/src/exec/common/histogram_helpers.hpp | 4 +-
be/src/exec/common/ipv6_to_binary.h | 4 +-
be/src/exec/common/join_utils.h | 106 ++--
be/src/exec/common/partition_sort_utils.cpp | 15 +-
be/src/exec/common/partition_sort_utils.h | 100 ++--
be/src/exec/common/set_utils.h | 91 ++-
be/src/exec/common/sip_hash.h | 28 +-
be/src/exec/common/stringop_substring.h | 10 +-
be/src/exec/common/template_helpers.hpp | 4 +-
be/src/exec/common/util.hpp | 4 +-
be/src/exec/common/varbinaryop_subbinary.h | 9 +-
be/src/exec/common/variant_util.cpp | 24 +-
be/src/exec/common/variant_util.h | 18 +-
be/src/exec/connector/jni_connector.cpp | 8 +-
be/src/exec/connector/jni_connector.h | 6 +-
.../exec/connector/skewed_partition_rebalancer.cpp | 4 +-
.../exec/connector/skewed_partition_rebalancer.h | 4 +-
be/src/exec/connector/vjdbc_connector.cpp | 19 +-
be/src/exec/connector/vjdbc_connector.h | 5 +-
be/src/exec/es/es_scroll_parser.cpp | 58 +-
be/src/exec/es/es_scroll_parser.h | 7 +-
be/src/exec/exchange/exchange_writer.cpp | 45 +-
be/src/exec/exchange/exchange_writer.h | 38 +-
.../exec/exchange/local_exchange_sink_operator.cpp | 18 +-
.../exec/exchange/local_exchange_sink_operator.h | 12 +-
.../exchange/local_exchange_source_operator.cpp | 7 +-
.../exec/exchange/local_exchange_source_operator.h | 6 +-
be/src/exec/exchange/local_exchanger.cpp | 95 ++--
be/src/exec/exchange/local_exchanger.h | 68 +--
be/src/exec/exchange/vdata_stream_mgr.cpp | 2 -
be/src/exec/exchange/vdata_stream_mgr.h | 4 -
be/src/exec/exchange/vdata_stream_recvr.cpp | 14 +-
be/src/exec/exchange/vdata_stream_recvr.h | 20 +-
be/src/exec/exchange/vdata_stream_sender.cpp | 10 +-
be/src/exec/exchange/vdata_stream_sender.h | 29 +-
be/src/exec/operator/aggregation_sink_operator.cpp | 460 ++++++++-------
be/src/exec/operator/aggregation_sink_operator.h | 53 +-
.../exec/operator/aggregation_source_operator.cpp | 206 ++++---
be/src/exec/operator/aggregation_source_operator.h | 36 +-
be/src/exec/operator/analytic_sink_operator.cpp | 79 ++-
be/src/exec/operator/analytic_sink_operator.h | 55 +-
be/src/exec/operator/analytic_source_operator.cpp | 7 +-
be/src/exec/operator/analytic_source_operator.h | 4 +-
be/src/exec/operator/assert_num_rows_operator.cpp | 16 +-
be/src/exec/operator/assert_num_rows_operator.h | 6 +-
be/src/exec/operator/blackhole_sink_operator.cpp | 6 +-
be/src/exec/operator/blackhole_sink_operator.h | 9 +-
be/src/exec/operator/cache_sink_operator.cpp | 8 +-
be/src/exec/operator/cache_sink_operator.h | 4 +-
be/src/exec/operator/cache_source_operator.cpp | 12 +-
be/src/exec/operator/cache_source_operator.h | 10 +-
be/src/exec/operator/data_queue.cpp | 15 +-
be/src/exec/operator/data_queue.h | 17 +-
be/src/exec/operator/datagen_operator.cpp | 10 +-
be/src/exec/operator/datagen_operator.h | 6 +-
be/src/exec/operator/dict_sink_operator.cpp | 25 +-
be/src/exec/operator/dict_sink_operator.h | 12 +-
.../distinct_streaming_aggregation_operator.cpp | 118 ++--
.../distinct_streaming_aggregation_operator.h | 34 +-
be/src/exec/operator/empty_set_operator.cpp | 7 +-
be/src/exec/operator/empty_set_operator.h | 6 +-
be/src/exec/operator/es_scan_operator.cpp | 8 +-
be/src/exec/operator/es_scan_operator.h | 10 +-
be/src/exec/operator/exchange_sink_buffer.cpp | 36 +-
be/src/exec/operator/exchange_sink_buffer.h | 24 +-
be/src/exec/operator/exchange_sink_operator.cpp | 42 +-
be/src/exec/operator/exchange_sink_operator.h | 25 +-
be/src/exec/operator/exchange_source_operator.cpp | 11 +-
be/src/exec/operator/exchange_source_operator.h | 14 +-
be/src/exec/operator/file_scan_operator.cpp | 33 +-
be/src/exec/operator/file_scan_operator.h | 25 +-
.../operator/group_commit_block_sink_operator.cpp | 27 +-
.../operator/group_commit_block_sink_operator.h | 20 +-
.../exec/operator/group_commit_scan_operator.cpp | 10 +-
be/src/exec/operator/group_commit_scan_operator.h | 8 +-
be/src/exec/operator/hashjoin_build_sink.cpp | 148 +++--
be/src/exec/operator/hashjoin_build_sink.h | 40 +-
be/src/exec/operator/hashjoin_probe_operator.cpp | 88 ++-
be/src/exec/operator/hashjoin_probe_operator.h | 48 +-
be/src/exec/operator/hive_table_sink_operator.cpp | 4 +-
be/src/exec/operator/hive_table_sink_operator.h | 20 +-
.../exec/operator/iceberg_table_sink_operator.cpp | 4 +-
be/src/exec/operator/iceberg_table_sink_operator.h | 20 +-
be/src/exec/operator/jdbc_scan_operator.cpp | 12 +-
be/src/exec/operator/jdbc_scan_operator.h | 10 +-
be/src/exec/operator/jdbc_table_sink_operator.cpp | 12 +-
be/src/exec/operator/jdbc_table_sink_operator.h | 17 +-
be/src/exec/operator/join/full_outer_join_impl.cpp | 2 +-
be/src/exec/operator/join/inner_join_impl.cpp | 2 +-
be/src/exec/operator/join/left_anti_join_impl.cpp | 2 +-
be/src/exec/operator/join/left_outer_join_impl.cpp | 2 +-
be/src/exec/operator/join/left_semi_join_impl.cpp | 2 +-
.../join/null_aware_left_anti_join_impl.cpp | 2 +-
.../join/null_aware_left_semi_join_impl.cpp | 2 +-
.../exec/operator/join/process_hash_table_probe.h | 47 +-
.../operator/join/process_hash_table_probe_impl.h | 171 +++---
be/src/exec/operator/join/right_anti_join_impl.cpp | 2 +-
.../exec/operator/join/right_outer_join_impl.cpp | 2 +-
be/src/exec/operator/join/right_semi_join_impl.cpp | 2 +-
be/src/exec/operator/join_build_sink_operator.cpp | 4 +-
be/src/exec/operator/join_build_sink_operator.h | 4 +-
be/src/exec/operator/join_probe_operator.cpp | 12 +-
be/src/exec/operator/join_probe_operator.h | 12 +-
.../operator/local_merge_sort_source_operator.cpp | 28 +-
.../operator/local_merge_sort_source_operator.h | 15 +-
be/src/exec/operator/materialization_opertor.cpp | 45 +-
be/src/exec/operator/materialization_opertor.h | 19 +-
.../operator/maxcompute_table_sink_operator.cpp | 4 +-
.../exec/operator/maxcompute_table_sink_operator.h | 21 +-
.../exec/operator/memory_scratch_sink_operator.cpp | 17 +-
.../exec/operator/memory_scratch_sink_operator.h | 10 +-
be/src/exec/operator/meta_scan_operator.cpp | 12 +-
be/src/exec/operator/meta_scan_operator.h | 10 +-
be/src/exec/operator/mock_operator.h | 12 +-
be/src/exec/operator/mock_scan_operator.h | 15 +-
.../exec/operator/multi_cast_data_stream_sink.cpp | 7 +-
be/src/exec/operator/multi_cast_data_stream_sink.h | 6 +-
.../operator/multi_cast_data_stream_source.cpp | 20 +-
.../exec/operator/multi_cast_data_stream_source.h | 28 +-
be/src/exec/operator/multi_cast_data_streamer.cpp | 30 +-
be/src/exec/operator/multi_cast_data_streamer.h | 25 +-
.../operator/nested_loop_join_build_operator.cpp | 15 +-
.../operator/nested_loop_join_build_operator.h | 12 +-
.../operator/nested_loop_join_probe_operator.cpp | 114 ++--
.../operator/nested_loop_join_probe_operator.h | 40 +-
be/src/exec/operator/olap_scan_operator.cpp | 65 +--
be/src/exec/operator/olap_scan_operator.h | 28 +-
be/src/exec/operator/olap_table_sink_operator.h | 20 +-
be/src/exec/operator/olap_table_sink_v2_operator.h | 20 +-
be/src/exec/operator/operator.cpp | 104 ++--
be/src/exec/operator/operator.h | 72 ++-
.../exec/operator/partition_sort_sink_operator.cpp | 37 +-
.../exec/operator/partition_sort_sink_operator.h | 25 +-
.../operator/partition_sort_source_operator.cpp | 8 +-
.../exec/operator/partition_sort_source_operator.h | 7 +-
.../partitioned_aggregation_sink_operator.cpp | 63 +-
.../partitioned_aggregation_sink_operator.h | 31 +-
.../partitioned_aggregation_source_operator.cpp | 22 +-
.../partitioned_aggregation_source_operator.h | 16 +-
.../partitioned_hash_join_probe_operator.cpp | 60 +-
.../partitioned_hash_join_probe_operator.h | 48 +-
.../partitioned_hash_join_sink_operator.cpp | 33 +-
.../operator/partitioned_hash_join_sink_operator.h | 15 +-
.../exec/operator/rec_cte_anchor_sink_operator.cpp | 14 +-
.../exec/operator/rec_cte_anchor_sink_operator.h | 10 +-
be/src/exec/operator/rec_cte_scan_operator.h | 10 +-
be/src/exec/operator/rec_cte_sink_operator.cpp | 14 +-
be/src/exec/operator/rec_cte_sink_operator.h | 10 +-
be/src/exec/operator/rec_cte_source_operator.cpp | 8 +-
be/src/exec/operator/rec_cte_source_operator.h | 8 +-
be/src/exec/operator/repeat_operator.cpp | 50 +-
be/src/exec/operator/repeat_operator.h | 22 +-
be/src/exec/operator/result_file_sink_operator.cpp | 16 +-
be/src/exec/operator/result_file_sink_operator.h | 20 +-
be/src/exec/operator/result_sink_operator.cpp | 21 +-
be/src/exec/operator/result_sink_operator.h | 11 +-
be/src/exec/operator/scan_operator.cpp | 153 +++--
be/src/exec/operator/scan_operator.h | 106 ++--
be/src/exec/operator/schema_scan_operator.cpp | 25 +-
be/src/exec/operator/schema_scan_operator.h | 6 +-
be/src/exec/operator/select_operator.h | 6 +-
be/src/exec/operator/set_probe_sink_operator.cpp | 25 +-
be/src/exec/operator/set_probe_sink_operator.h | 20 +-
be/src/exec/operator/set_sink_operator.cpp | 31 +-
be/src/exec/operator/set_sink_operator.h | 22 +-
be/src/exec/operator/set_source_operator.cpp | 22 +-
be/src/exec/operator/set_source_operator.h | 15 +-
be/src/exec/operator/sort_sink_operator.cpp | 23 +-
be/src/exec/operator/sort_sink_operator.h | 16 +-
be/src/exec/operator/sort_source_operator.cpp | 9 +-
be/src/exec/operator/sort_source_operator.h | 7 +-
.../operator/spill_iceberg_table_sink_operator.cpp | 22 +-
.../operator/spill_iceberg_table_sink_operator.h | 14 +-
be/src/exec/operator/spill_sort_sink_operator.cpp | 13 +-
be/src/exec/operator/spill_sort_sink_operator.h | 10 +-
.../exec/operator/spill_sort_source_operator.cpp | 31 +-
be/src/exec/operator/spill_sort_source_operator.h | 12 +-
be/src/exec/operator/spill_utils.h | 11 +-
.../operator/streaming_aggregation_operator.cpp | 477 ++++++++--------
.../exec/operator/streaming_aggregation_operator.h | 106 ++--
be/src/exec/operator/table_function_operator.cpp | 86 +--
be/src/exec/operator/table_function_operator.h | 30 +-
be/src/exec/operator/tvf_table_sink_operator.cpp | 4 +-
be/src/exec/operator/tvf_table_sink_operator.h | 20 +-
be/src/exec/operator/union_sink_operator.cpp | 18 +-
be/src/exec/operator/union_sink_operator.h | 33 +-
be/src/exec/operator/union_source_operator.cpp | 23 +-
be/src/exec/operator/union_source_operator.h | 22 +-
be/src/exec/partitioner/partitioner.cpp | 4 +-
be/src/exec/partitioner/partitioner.h | 4 +-
be/src/exec/pipeline/dependency.cpp | 153 +++--
be/src/exec/pipeline/dependency.h | 121 ++--
be/src/exec/pipeline/pipeline.cpp | 4 +-
be/src/exec/pipeline/pipeline.h | 4 +-
be/src/exec/pipeline/pipeline_fragment_context.cpp | 9 +-
be/src/exec/pipeline/pipeline_fragment_context.h | 5 +-
be/src/exec/pipeline/pipeline_task.cpp | 13 +-
be/src/exec/pipeline/pipeline_task.h | 8 +-
be/src/exec/pipeline/pipeline_tracing.cpp | 4 +-
be/src/exec/pipeline/pipeline_tracing.h | 4 +-
be/src/exec/pipeline/rec_cte_shared_state.h | 79 ++-
be/src/exec/pipeline/revokable_task.h | 2 -
be/src/exec/pipeline/task_queue.cpp | 4 +-
be/src/exec/pipeline/task_queue.h | 4 +-
be/src/exec/pipeline/task_scheduler.cpp | 4 +-
be/src/exec/pipeline/task_scheduler.h | 4 +-
be/src/exec/rowid_fetcher.cpp | 102 ++--
be/src/exec/rowid_fetcher.h | 27 +-
be/src/exec/runtime_filter/runtime_filter.cpp | 9 +-
.../runtime_filter/runtime_filter_consumer.cpp | 65 ++-
.../exec/runtime_filter/runtime_filter_consumer.h | 13 +-
.../runtime_filter_consumer_helper.cpp | 27 +-
.../runtime_filter_consumer_helper.h | 11 +-
be/src/exec/runtime_filter/runtime_filter_merger.h | 4 +-
.../runtime_filter/runtime_filter_producer.cpp | 10 +-
.../exec/runtime_filter/runtime_filter_producer.h | 6 +-
.../runtime_filter_producer_helper.cpp | 12 +-
.../runtime_filter_producer_helper.h | 12 +-
.../runtime_filter_producer_helper_cross.h | 6 +-
.../runtime_filter_producer_helper_set.h | 2 +-
.../exec/runtime_filter/runtime_filter_wrapper.cpp | 12 +-
.../exec/runtime_filter/runtime_filter_wrapper.h | 4 +-
be/src/exec/runtime_filter/utils.cpp | 11 +-
be/src/exec/runtime_filter/utils.h | 18 +-
be/src/exec/scan/es_scanner.cpp | 18 +-
be/src/exec/scan/es_scanner.h | 12 +-
be/src/exec/scan/file_scanner.cpp | 74 ++-
be/src/exec/scan/file_scanner.h | 18 +-
be/src/exec/scan/jdbc_scanner.cpp | 8 +-
be/src/exec/scan/jdbc_scanner.h | 4 +-
be/src/exec/scan/meta_scanner.cpp | 35 +-
be/src/exec/scan/meta_scanner.h | 8 +-
be/src/exec/scan/olap_scanner.cpp | 30 +-
be/src/exec/scan/olap_scanner.h | 17 +-
be/src/exec/scan/parallel_scanner_builder.cpp | 2 -
be/src/exec/scan/parallel_scanner_builder.h | 16 +-
be/src/exec/scan/scan_node.h | 4 +-
be/src/exec/scan/scanner.cpp | 12 +-
be/src/exec/scan/scanner.h | 22 +-
be/src/exec/scan/scanner_context.cpp | 35 +-
be/src/exec/scan/scanner_context.h | 29 +-
be/src/exec/scan/scanner_scheduler.cpp | 13 +-
be/src/exec/scan/scanner_scheduler.h | 30 +-
be/src/exec/scan/simplified_scan_scheduler.cpp | 4 +-
be/src/exec/scan/split_source_connector.cpp | 4 +-
be/src/exec/scan/split_source_connector.h | 5 +-
be/src/exec/scan/task_executor/listenable_future.h | 2 -
be/src/exec/scan/task_executor/split_runner.h | 2 -
be/src/exec/scan/task_executor/task_executor.h | 2 -
be/src/exec/scan/task_executor/task_handle.h | 2 -
be/src/exec/scan/task_executor/task_id.h | 6 +-
be/src/exec/scan/task_executor/ticker.h | 2 -
.../time_sharing/multilevel_split_queue.cpp | 2 -
.../time_sharing/multilevel_split_queue.h | 2 -
.../time_sharing/prioritized_split_runner.cpp | 2 -
.../time_sharing/prioritized_split_runner.h | 2 -
.../scan/task_executor/time_sharing/priority.h | 2 -
.../time_sharing/split_concurrency_controller.h | 4 +-
.../scan/task_executor/time_sharing/split_queue.h | 2 -
.../time_sharing/time_sharing_task_executor.cpp | 36 +-
.../time_sharing/time_sharing_task_executor.h | 2 -
.../time_sharing/time_sharing_task_handle.cpp | 2 -
.../time_sharing/time_sharing_task_handle.h | 2 -
.../task_executor/tools/simulator/histogram.cpp | 2 -
.../scan/task_executor/tools/simulator/histogram.h | 2 -
.../tools/simulator/scheduled_executor.h | 2 -
.../tools/simulator/simulation_controller.cpp | 2 -
.../tools/simulator/simulation_controller.h | 2 -
.../tools/simulator/simulation_fifo_split_queue.h | 2 -
.../tools/simulator/simulation_split.cpp | 2 -
.../tools/simulator/simulation_split.h | 2 -
.../tools/simulator/simulation_task.cpp | 2 -
.../tools/simulator/simulation_task.h | 4 +-
.../tools/simulator/split_generators.cpp | 22 +-
.../tools/simulator/split_generators.h | 2 -
.../tools/simulator/split_specification.cpp | 2 -
.../tools/simulator/split_specification.h | 2 -
.../tools/simulator/task_executor_simulator.cpp | 4 +-
.../tools/simulator/task_executor_simulator.h | 2 -
be/src/exec/sink/autoinc_buffer.cpp | 4 +-
be/src/exec/sink/autoinc_buffer.h | 4 +-
be/src/exec/sink/delta_writer_v2_pool.cpp | 3 -
be/src/exec/sink/delta_writer_v2_pool.h | 3 -
.../sink/scale_writer_partitioning_exchanger.hpp | 7 +-
be/src/exec/sink/tablet_sink_hash_partitioner.cpp | 19 +-
be/src/exec/sink/tablet_sink_hash_partitioner.h | 18 +-
be/src/exec/sink/vrow_distribution.cpp | 6 +-
be/src/exec/sink/vrow_distribution.h | 4 +-
be/src/exec/sink/vtablet_block_convertor.cpp | 156 +++--
be/src/exec/sink/vtablet_block_convertor.h | 35 +-
be/src/exec/sink/vtablet_finder.cpp | 4 +-
be/src/exec/sink/vtablet_finder.h | 10 +-
be/src/exec/sink/writer/async_result_writer.cpp | 18 +-
be/src/exec/sink/writer/async_result_writer.h | 14 +-
be/src/exec/sink/writer/iceberg/partition_data.h | 6 +-
.../sink/writer/iceberg/partition_transformers.cpp | 2 -
.../sink/writer/iceberg/partition_transformers.h | 32 +-
.../writer/iceberg/viceberg_partition_writer.cpp | 4 +-
.../writer/iceberg/viceberg_partition_writer.h | 5 +-
.../sink/writer/iceberg/viceberg_sort_writer.cpp | 22 +-
.../sink/writer/iceberg/viceberg_sort_writer.h | 21 +-
.../sink/writer/iceberg/viceberg_table_writer.cpp | 40 +-
.../sink/writer/iceberg/viceberg_table_writer.h | 18 +-
.../sink/writer/iceberg/vpartition_writer_base.h | 5 +-
.../writer/maxcompute/vmc_partition_writer.cpp | 4 +-
.../sink/writer/maxcompute/vmc_partition_writer.h | 5 +-
.../sink/writer/maxcompute/vmc_table_writer.cpp | 11 +-
.../exec/sink/writer/maxcompute/vmc_table_writer.h | 8 +-
be/src/exec/sink/writer/result_writer.h | 4 +-
.../sink/writer/varrow_flight_result_writer.cpp | 14 +-
.../exec/sink/writer/varrow_flight_result_writer.h | 12 +-
be/src/exec/sink/writer/vfile_result_writer.cpp | 16 +-
be/src/exec/sink/writer/vfile_result_writer.h | 18 +-
be/src/exec/sink/writer/vhive_partition_writer.cpp | 4 +-
be/src/exec/sink/writer/vhive_partition_writer.h | 5 +-
be/src/exec/sink/writer/vhive_table_writer.cpp | 30 +-
be/src/exec/sink/writer/vhive_table_writer.h | 16 +-
be/src/exec/sink/writer/vhive_utils.cpp | 2 -
be/src/exec/sink/writer/vhive_utils.h | 2 -
be/src/exec/sink/writer/vjdbc_table_writer.cpp | 8 +-
be/src/exec/sink/writer/vjdbc_table_writer.h | 7 +-
be/src/exec/sink/writer/vmysql_result_writer.cpp | 4 +-
be/src/exec/sink/writer/vmysql_result_writer.h | 2 -
be/src/exec/sink/writer/vtablet_writer.cpp | 22 +-
be/src/exec/sink/writer/vtablet_writer.h | 26 +-
be/src/exec/sink/writer/vtablet_writer_v2.cpp | 14 +-
be/src/exec/sink/writer/vtablet_writer_v2.h | 9 +-
be/src/exec/sink/writer/vtvf_table_writer.cpp | 10 +-
be/src/exec/sink/writer/vtvf_table_writer.h | 7 +-
be/src/exec/sink/writer/vwal_writer.cpp | 4 +-
be/src/exec/sink/writer/vwal_writer.h | 4 +-
be/src/exec/sort/heap_sorter.cpp | 4 +-
be/src/exec/sort/heap_sorter.h | 4 +-
be/src/exec/sort/hybrid_sorter.h | 4 +-
be/src/exec/sort/partition_sorter.cpp | 6 +-
be/src/exec/sort/partition_sorter.h | 6 +-
be/src/exec/sort/sort_block.cpp | 4 +-
be/src/exec/sort/sort_block.h | 8 +-
be/src/exec/sort/sort_cursor.h | 4 +-
be/src/exec/sort/sort_description.h | 4 +-
be/src/exec/sort/sorter.cpp | 16 +-
be/src/exec/sort/sorter.h | 14 +-
be/src/exec/sort/topn_sorter.cpp | 6 +-
be/src/exec/sort/topn_sorter.h | 6 +-
be/src/exec/sort/vsort_exec_exprs.cpp | 4 +-
be/src/exec/sort/vsort_exec_exprs.h | 2 -
be/src/exec/sort/vsorted_run_merger.cpp | 4 +-
be/src/exec/sort/vsorted_run_merger.h | 4 +-
be/src/exec/spill/spill_file.cpp | 4 +-
be/src/exec/spill/spill_file.h | 3 -
be/src/exec/spill/spill_file_manager.cpp | 20 +-
be/src/exec/spill/spill_file_manager.h | 7 +-
be/src/exec/spill/spill_file_reader.cpp | 3 -
be/src/exec/spill/spill_file_reader.h | 7 +-
be/src/exec/spill/spill_file_writer.cpp | 4 +-
be/src/exec/spill/spill_file_writer.h | 2 -
be/src/exec/spill/spill_repartitioner.cpp | 52 +-
be/src/exec/spill/spill_repartitioner.h | 58 +-
be/src/exec/table_connector.h | 8 +-
be/src/exprs/aggregate/aggregate_function.h | 4 +-
.../exprs/aggregate/aggregate_function_ai_agg.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_ai_agg.h | 4 +-
.../aggregate_function_approx_count_distinct.cpp | 4 +-
.../aggregate_function_approx_count_distinct.h | 6 +-
.../aggregate/aggregate_function_array_agg.cpp | 4 +-
.../exprs/aggregate/aggregate_function_array_agg.h | 4 +-
be/src/exprs/aggregate/aggregate_function_avg.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_avg.h | 4 +-
.../aggregate/aggregate_function_avg_weighted.cpp | 4 +-
.../aggregate/aggregate_function_avg_weighted.h | 4 +-
be/src/exprs/aggregate/aggregate_function_binary.h | 4 +-
be/src/exprs/aggregate/aggregate_function_bit.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_bit.h | 4 +-
.../exprs/aggregate/aggregate_function_bitmap.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_bitmap.h | 4 +-
.../aggregate/aggregate_function_bitmap_agg.cpp | 4 +-
.../aggregate/aggregate_function_bitmap_agg.h | 6 +-
.../aggregate/aggregate_function_bool_union.cpp | 4 +-
.../aggregate/aggregate_function_bool_union.h | 4 +-
.../exprs/aggregate/aggregate_function_collect.cpp | 4 +-
.../exprs/aggregate/aggregate_function_collect.h | 4 +-
.../aggregate/aggregate_function_combinator.h | 4 +-
be/src/exprs/aggregate/aggregate_function_corr.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_corr.h | 4 +-
.../exprs/aggregate/aggregate_function_count.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_count.h | 9 +-
.../aggregate/aggregate_function_count_by_enum.cpp | 4 +-
.../aggregate/aggregate_function_count_by_enum.h | 4 +-
.../exprs/aggregate/aggregate_function_covar.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_covar.h | 4 +-
.../aggregate/aggregate_function_distinct.cpp | 4 +-
.../exprs/aggregate/aggregate_function_distinct.h | 6 +-
.../exprs/aggregate/aggregate_function_foreach.cpp | 4 +-
.../exprs/aggregate/aggregate_function_foreach.h | 4 +-
.../aggregate/aggregate_function_foreachv2.cpp | 4 +-
.../aggregate_function_group_array_set_op.cpp | 4 +-
.../aggregate_function_group_array_set_op.h | 8 +-
.../aggregate/aggregate_function_group_concat.cpp | 4 +-
.../aggregate/aggregate_function_group_concat.h | 6 +-
.../aggregate/aggregate_function_histogram.cpp | 4 +-
.../exprs/aggregate/aggregate_function_histogram.h | 4 +-
.../aggregate/aggregate_function_hll_union_agg.cpp | 4 +-
.../aggregate/aggregate_function_hll_union_agg.h | 6 +-
.../exprs/aggregate/aggregate_function_java_udaf.h | 4 +-
.../aggregate/aggregate_function_kurtosis.cpp | 4 +-
.../aggregate_function_linear_histogram.cpp | 4 +-
.../aggregate_function_linear_histogram.h | 4 +-
be/src/exprs/aggregate/aggregate_function_map.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_map.h | 4 +-
.../exprs/aggregate/aggregate_function_map_v2.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_map_v2.h | 4 +-
.../exprs/aggregate/aggregate_function_min_max.cpp | 4 +-
.../exprs/aggregate/aggregate_function_min_max.h | 6 +-
.../aggregate/aggregate_function_min_max_by.cpp | 4 +-
.../aggregate/aggregate_function_min_max_by.h | 4 +-
be/src/exprs/aggregate/aggregate_function_null.h | 4 +-
.../exprs/aggregate/aggregate_function_null_v2.h | 4 +-
.../aggregate_function_orthogonal_bitmap.cpp | 4 +-
.../aggregate_function_orthogonal_bitmap.h | 4 +-
.../aggregate/aggregate_function_percentile.cpp | 4 +-
.../aggregate/aggregate_function_percentile.h | 4 +-
.../aggregate_function_percentile_reservoir.cpp | 4 +-
.../aggregate_function_percentile_reservoir.h | 4 +-
.../exprs/aggregate/aggregate_function_product.h | 2 -
.../aggregate/aggregate_function_python_udaf.cpp | 4 +-
.../aggregate/aggregate_function_python_udaf.h | 4 +-
.../aggregate_function_quantile_state.cpp | 4 +-
.../aggregate/aggregate_function_quantile_state.h | 6 +-
.../exprs/aggregate/aggregate_function_reader.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_reader.h | 6 +-
.../aggregate_function_reader_first_last.h | 4 +-
.../aggregate/aggregate_function_regr_union.cpp | 4 +-
.../aggregate/aggregate_function_regr_union.h | 4 +-
.../aggregate/aggregate_function_retention.cpp | 4 +-
.../exprs/aggregate/aggregate_function_retention.h | 6 +-
be/src/exprs/aggregate/aggregate_function_rpc.h | 4 +-
be/src/exprs/aggregate/aggregate_function_sem.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_sem.h | 4 +-
.../aggregate_function_sequence_match.cpp | 4 +-
.../aggregate/aggregate_function_sequence_match.h | 6 +-
.../aggregate_function_simple_factory.cpp | 4 +-
.../aggregate/aggregate_function_simple_factory.h | 4 +-
be/src/exprs/aggregate/aggregate_function_skew.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_sort.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_sort.h | 6 +-
.../aggregate/aggregate_function_state_merge.h | 4 +-
.../aggregate/aggregate_function_state_union.h | 4 +-
.../exprs/aggregate/aggregate_function_statistic.h | 4 +-
.../exprs/aggregate/aggregate_function_stddev.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_stddev.h | 4 +-
be/src/exprs/aggregate/aggregate_function_sum.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_sum.h | 4 +-
be/src/exprs/aggregate/aggregate_function_topn.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_topn.h | 4 +-
be/src/exprs/aggregate/aggregate_function_uniq.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_uniq.h | 4 +-
.../aggregate_function_uniq_distribute_key.cpp | 4 +-
.../aggregate_function_uniq_distribute_key.h | 4 +-
.../exprs/aggregate/aggregate_function_window.cpp | 4 +-
be/src/exprs/aggregate/aggregate_function_window.h | 12 +-
.../aggregate/aggregate_function_window_funnel.cpp | 4 +-
.../aggregate/aggregate_function_window_funnel.h | 6 +-
be/src/exprs/aggregate/factory_helpers.h | 4 +-
be/src/exprs/aggregate/helpers.h | 4 +-
be/src/exprs/aggregate/moments.h | 4 +-
be/src/exprs/bloom_filter_func.h | 10 +-
be/src/exprs/bloom_filter_func_adaptor.h | 59 +-
be/src/exprs/bloom_filter_func_impl.h | 4 +-
be/src/exprs/function/ai/ai_adapter.h | 4 +-
be/src/exprs/function/ai/ai_classify.h | 4 +-
be/src/exprs/function/ai/ai_extract.h | 4 +-
be/src/exprs/function/ai/ai_filter.h | 4 +-
be/src/exprs/function/ai/ai_fix_grammar.h | 4 +-
be/src/exprs/function/ai/ai_functions.cpp | 4 +-
be/src/exprs/function/ai/ai_functions.h | 4 +-
be/src/exprs/function/ai/ai_generate.h | 4 +-
be/src/exprs/function/ai/ai_mask.h | 4 +-
be/src/exprs/function/ai/ai_sentiment.h | 4 +-
be/src/exprs/function/ai/ai_similarity.h | 4 +-
be/src/exprs/function/ai/ai_summarize.h | 4 +-
be/src/exprs/function/ai/ai_translate.h | 4 +-
be/src/exprs/function/ai/embed.h | 4 +-
.../function/array/function_array_aggregation.cpp | 4 +-
.../exprs/function/array/function_array_apply.cpp | 4 +-
.../exprs/function/array/function_array_binary.h | 4 +-
.../function/array/function_array_compact.cpp | 4 +-
.../exprs/function/array/function_array_compact.h | 4 +-
.../exprs/function/array/function_array_concat.cpp | 4 +-
.../function/array/function_array_constructor.cpp | 4 +-
.../function/array/function_array_contains_all.cpp | 4 +-
.../exprs/function/array/function_array_count.cpp | 4 +-
.../function/array/function_array_cum_sum.cpp | 4 +-
.../function/array/function_array_difference.cpp | 4 +-
.../function/array/function_array_difference.h | 4 +-
.../function/array/function_array_distance.cpp | 4 +-
.../exprs/function/array/function_array_distance.h | 4 +-
.../function/array/function_array_distinct.cpp | 4 +-
.../exprs/function/array/function_array_distinct.h | 4 +-
.../function/array/function_array_element.cpp | 4 +-
.../exprs/function/array/function_array_element.h | 4 +-
.../function/array/function_array_enumerate.cpp | 4 +-
.../array/function_array_enumerate_uniq.cpp | 4 +-
.../exprs/function/array/function_array_except.cpp | 4 +-
.../exprs/function/array/function_array_exists.cpp | 4 +-
.../exprs/function/array/function_array_filter.cpp | 6 +-
.../array/function_array_first_or_last_index.cpp | 4 +-
.../function/array/function_array_flatten.cpp | 4 +-
.../exprs/function/array/function_array_index.cpp | 4 +-
be/src/exprs/function/array/function_array_index.h | 6 +-
.../function/array/function_array_intersect.cpp | 4 +-
be/src/exprs/function/array/function_array_join.h | 4 +-
be/src/exprs/function/array/function_array_map.h | 4 +-
.../exprs/function/array/function_array_mapped.h | 2 -
be/src/exprs/function/array/function_array_nary.h | 4 +-
be/src/exprs/function/array/function_array_pop.cpp | 4 +-
.../function/array/function_array_pushback.cpp | 4 +-
.../function/array/function_array_pushfront.cpp | 4 +-
.../exprs/function/array/function_array_range.cpp | 8 +-
.../function/array/function_array_register.cpp | 4 +-
.../exprs/function/array/function_array_remove.cpp | 4 +-
.../exprs/function/array/function_array_remove.h | 4 +-
.../exprs/function/array/function_array_reverse.h | 4 +-
be/src/exprs/function/array/function_array_set.h | 4 +-
.../function/array/function_array_shuffle.cpp | 4 +-
.../exprs/function/array/function_array_slice.cpp | 4 +-
be/src/exprs/function/array/function_array_slice.h | 4 +-
.../exprs/function/array/function_array_sort.cpp | 4 +-
be/src/exprs/function/array/function_array_sort.h | 4 +-
.../exprs/function/array/function_array_sortby.cpp | 4 +-
.../exprs/function/array/function_array_split.cpp | 4 +-
.../exprs/function/array/function_array_union.cpp | 4 +-
.../exprs/function/array/function_array_utils.cpp | 4 +-
be/src/exprs/function/array/function_array_utils.h | 6 +-
.../array/function_array_with_constant.cpp | 6 +-
be/src/exprs/function/array/function_array_zip.cpp | 4 +-
.../function/array/function_arrays_overlap.cpp | 4 +-
.../exprs/function/array/function_arrays_overlap.h | 6 +-
.../exprs/function/array/varray_match_function.cpp | 4 +-
be/src/exprs/function/binary_arithmetic.h | 4 +-
be/src/exprs/function/cast/cast_base.cpp | 6 +-
be/src/exprs/function/cast/cast_base.h | 4 +-
be/src/exprs/function/cast/cast_parameters.h | 4 +-
be/src/exprs/function/cast/cast_to_array.h | 4 +-
.../function/cast/cast_to_basic_number_common.h | 6 +-
be/src/exprs/function/cast/cast_to_boolean.h | 4 +-
be/src/exprs/function/cast/cast_to_date.h | 4 +-
.../cast/cast_to_date_or_datetime_impl.hpp | 4 +-
.../function/cast/cast_to_datetimev2_impl.hpp | 4 +-
be/src/exprs/function/cast/cast_to_datev2_impl.hpp | 4 +-
be/src/exprs/function/cast/cast_to_decimal.h | 13 +-
be/src/exprs/function/cast/cast_to_float.h | 4 +-
be/src/exprs/function/cast/cast_to_int.h | 4 +-
be/src/exprs/function/cast/cast_to_ip.h | 4 +-
be/src/exprs/function/cast/cast_to_jsonb.h | 4 +-
be/src/exprs/function/cast/cast_to_map.h | 4 +-
be/src/exprs/function/cast/cast_to_string.h | 4 +-
be/src/exprs/function/cast/cast_to_struct.h | 4 +-
be/src/exprs/function/cast/cast_to_time_impl.hpp | 4 +-
be/src/exprs/function/cast/cast_to_timestamptz.h | 4 +-
be/src/exprs/function/cast/cast_to_variant.h | 4 +-
be/src/exprs/function/cast/function_cast.cpp | 4 +-
be/src/exprs/function/cast_type_to_either.h | 4 +-
be/src/exprs/function/comparison.cpp | 4 +-
.../exprs/function/comparison_equal_for_null.cpp | 4 +-
be/src/exprs/function/comparison_equals.cpp | 4 +-
be/src/exprs/function/comparison_greater.cpp | 4 +-
be/src/exprs/function/comparison_less.cpp | 4 +-
be/src/exprs/function/complex_dict_hash_map.h | 10 +-
.../exprs/function/complex_hash_map_dictionary.cpp | 118 ++--
.../exprs/function/complex_hash_map_dictionary.h | 4 +-
be/src/exprs/function/date_format_type.h | 4 +-
be/src/exprs/function/date_time_transforms.h | 14 +-
be/src/exprs/function/datetime_errors.h | 4 +-
be/src/exprs/function/dictionary.cpp | 6 +-
be/src/exprs/function/dictionary.h | 4 +-
be/src/exprs/function/dictionary_factory.cpp | 4 +-
be/src/exprs/function/dictionary_factory.h | 4 +-
be/src/exprs/function/dictionary_util.h | 4 +-
be/src/exprs/function/divide.cpp | 4 +-
be/src/exprs/function/function.cpp | 4 +-
be/src/exprs/function/function.h | 8 +-
be/src/exprs/function/function_agg_state.h | 4 +-
.../exprs/function/function_always_not_nullable.h | 4 +-
be/src/exprs/function/function_assert_true.cpp | 4 +-
be/src/exprs/function/function_bit.cpp | 4 +-
be/src/exprs/function/function_bit_count.cpp | 4 +-
be/src/exprs/function/function_bit_shift.cpp | 4 +-
be/src/exprs/function/function_bit_test.cpp | 4 +-
be/src/exprs/function/function_bitmap.cpp | 4 +-
be/src/exprs/function/function_bitmap_min_or_max.h | 4 +-
be/src/exprs/function/function_bitmap_variadic.cpp | 4 +-
be/src/exprs/function/function_collection_in.cpp | 4 +-
be/src/exprs/function/function_collection_in.h | 10 +-
be/src/exprs/function/function_compress.cpp | 4 +-
be/src/exprs/function/function_const.h | 4 +-
be/src/exprs/function/function_conv.cpp | 4 +-
be/src/exprs/function/function_convert_tz.cpp | 4 +-
.../function_date_or_datetime_computation.cpp | 4 +-
.../function_date_or_datetime_computation.h | 4 +-
.../function_date_or_datetime_to_something.h | 4 +-
.../function_date_or_datetime_to_string.cpp | 4 +-
.../function/function_datetime_floor_ceil.cpp | 4 +-
.../function_datetime_string_to_string.cpp | 4 +-
.../function/function_datetime_string_to_string.h | 4 +-
be/src/exprs/function/function_decode_varchar.cpp | 4 +-
be/src/exprs/function/function_dict_get.cpp | 4 +-
be/src/exprs/function/function_dict_get_many.cpp | 4 +-
be/src/exprs/function/function_encode_varchar.cpp | 4 +-
be/src/exprs/function/function_encryption.cpp | 4 +-
be/src/exprs/function/function_fake.cpp | 12 +-
be/src/exprs/function/function_fake.h | 6 +-
be/src/exprs/function/function_format.cpp | 4 +-
be/src/exprs/function/function_grouping.cpp | 4 +-
be/src/exprs/function/function_grouping.h | 4 +-
be/src/exprs/function/function_hash.cpp | 4 +-
be/src/exprs/function/function_hash.h | 4 +-
be/src/exprs/function/function_helpers.cpp | 4 +-
be/src/exprs/function/function_helpers.h | 4 +-
be/src/exprs/function/function_hex.cpp | 12 +-
be/src/exprs/function/function_hll.cpp | 4 +-
be/src/exprs/function/function_ifnull.h | 4 +-
be/src/exprs/function/function_ignore.cpp | 4 +-
be/src/exprs/function/function_interval.cpp | 4 +-
be/src/exprs/function/function_ip.cpp | 4 +-
be/src/exprs/function/function_ip.h | 6 +-
be/src/exprs/function/function_java_udf.cpp | 4 +-
be/src/exprs/function/function_java_udf.h | 4 +-
be/src/exprs/function/function_json.cpp | 4 +-
be/src/exprs/function/function_json_hash.cpp | 4 +-
be/src/exprs/function/function_jsonb.cpp | 15 +-
be/src/exprs/function/function_jsonb_transform.cpp | 4 +-
be/src/exprs/function/function_map.cpp | 4 +-
be/src/exprs/function/function_math_log.h | 4 +-
be/src/exprs/function/function_math_unary.h | 4 +-
.../function/function_math_unary_alway_nullable.h | 4 +-
be/src/exprs/function/function_multi_match.cpp | 6 +-
be/src/exprs/function/function_multi_match.h | 6 +-
be/src/exprs/function/function_multi_same_args.h | 4 +-
.../exprs/function/function_needs_to_handle_null.h | 4 +-
be/src/exprs/function/function_nullables.cpp | 4 +-
.../function/function_other_types_to_date.cpp | 4 +-
be/src/exprs/function/function_python_udf.cpp | 8 +-
be/src/exprs/function/function_python_udf.h | 4 +-
be/src/exprs/function/function_quantile_state.cpp | 4 +-
be/src/exprs/function/function_regexp.cpp | 4 +-
be/src/exprs/function/function_reverse.h | 4 +-
be/src/exprs/function/function_rpc.cpp | 4 +-
be/src/exprs/function/function_rpc.h | 13 +-
be/src/exprs/function/function_score.cpp | 4 +-
be/src/exprs/function/function_search.cpp | 15 +-
be/src/exprs/function/function_search.h | 20 +-
be/src/exprs/function/function_size.cpp | 4 +-
be/src/exprs/function/function_soundex.cpp | 4 +-
be/src/exprs/function/function_split_by_regexp.cpp | 4 +-
be/src/exprs/function/function_string.cpp | 4 +-
be/src/exprs/function/function_string.h | 68 +--
be/src/exprs/function/function_string_to_string.h | 4 +-
be/src/exprs/function/function_struct.cpp | 4 +-
be/src/exprs/function/function_struct_element.cpp | 4 +-
.../function/function_time_value_to_field.cpp | 4 +-
be/src/exprs/function/function_to_json.cpp | 4 +-
be/src/exprs/function/function_tokenize.cpp | 6 +-
be/src/exprs/function/function_tokenize.h | 6 +-
be/src/exprs/function/function_totype.h | 6 +-
be/src/exprs/function/function_unary_arithmetic.h | 4 +-
be/src/exprs/function/function_utility.cpp | 4 +-
be/src/exprs/function/function_uuid.cpp | 4 +-
be/src/exprs/function/function_varbinary.cpp | 4 +-
be/src/exprs/function/function_varbinary.h | 4 +-
.../exprs/function/function_variadic_arguments.h | 4 +-
be/src/exprs/function/function_variant_element.cpp | 17 +-
be/src/exprs/function/function_variant_type.cpp | 4 +-
be/src/exprs/function/function_width_bucket.cpp | 4 +-
be/src/exprs/function/functions_comparison.h | 6 +-
be/src/exprs/function/functions_logical.cpp | 4 +-
be/src/exprs/function/functions_logical.h | 6 +-
.../function/functions_multi_string_position.cpp | 7 +-
.../function/functions_multi_string_search.cpp | 7 +-
be/src/exprs/function/geo/functions_geo.cpp | 4 +-
be/src/exprs/function/geo/functions_geo.h | 6 +-
be/src/exprs/function/if.cpp | 6 +-
be/src/exprs/function/if.h | 4 +-
be/src/exprs/function/in.cpp | 4 +-
be/src/exprs/function/in.h | 19 +-
be/src/exprs/function/int_div.cpp | 4 +-
be/src/exprs/function/ip_address_dictionary.cpp | 4 +-
be/src/exprs/function/ip_address_dictionary.h | 4 +-
be/src/exprs/function/is_not_null.cpp | 4 +-
be/src/exprs/function/is_not_null.h | 6 +-
be/src/exprs/function/is_null.cpp | 4 +-
be/src/exprs/function/is_null.h | 6 +-
be/src/exprs/function/least_greast.cpp | 4 +-
be/src/exprs/function/like.cpp | 17 +-
be/src/exprs/function/like.h | 4 +-
be/src/exprs/function/match.cpp | 8 +-
be/src/exprs/function/match.h | 6 +-
be/src/exprs/function/math.cpp | 4 +-
be/src/exprs/function/minus.cpp | 4 +-
be/src/exprs/function/modulo.cpp | 4 +-
be/src/exprs/function/multiply.cpp | 4 +-
be/src/exprs/function/nullif.cpp | 8 +-
be/src/exprs/function/plus.cpp | 4 +-
be/src/exprs/function/random.cpp | 4 +-
be/src/exprs/function/regexps.h | 4 +-
be/src/exprs/function/round.cpp | 4 +-
be/src/exprs/function/round.h | 13 +-
be/src/exprs/function/simple_function_factory.h | 4 +-
be/src/exprs/function/string_hex_util.h | 4 +-
be/src/exprs/function/time_of_function.cpp | 4 +-
be/src/exprs/function/to_time_function.cpp | 4 +-
be/src/exprs/function/uniform.cpp | 4 +-
be/src/exprs/function/url/domain.h | 4 +-
be/src/exprs/function/url/function_url.cpp | 4 +-
be/src/exprs/function/url/functions_url.h | 4 +-
be/src/exprs/function/url/protocol.h | 4 +-
be/src/exprs/function/uuid.cpp | 4 +-
be/src/exprs/function/uuid_numeric.cpp | 4 +-
be/src/exprs/function_context.cpp | 8 +-
be/src/exprs/function_context.h | 18 +-
be/src/exprs/hybrid_set.h | 167 +++---
be/src/exprs/lambda_function/lambda_function.h | 6 +-
.../lambda_function/lambda_function_factory.h | 4 +-
.../lambda_function/varray_filter_function.cpp | 12 +-
.../exprs/lambda_function/varray_map_function.cpp | 14 +-
.../exprs/lambda_function/varray_sort_function.cpp | 14 +-
be/src/exprs/minmax_predicate.h | 27 +-
be/src/exprs/score_runtime.h | 4 +-
be/src/exprs/short_circuit_evaluation_expr.cpp | 4 +-
be/src/exprs/short_circuit_evaluation_expr.h | 4 +-
be/src/exprs/short_circuit_util.h | 4 +-
.../exprs/table_function/python_udtf_function.cpp | 6 +-
be/src/exprs/table_function/python_udtf_function.h | 4 +-
be/src/exprs/table_function/table_function.h | 4 +-
.../table_function/table_function_factory.cpp | 4 +-
.../exprs/table_function/table_function_factory.h | 2 -
be/src/exprs/table_function/udf_table_function.cpp | 4 +-
be/src/exprs/table_function/udf_table_function.h | 4 +-
be/src/exprs/table_function/vexplode.cpp | 4 +-
be/src/exprs/table_function/vexplode.h | 8 +-
be/src/exprs/table_function/vexplode_bitmap.cpp | 4 +-
be/src/exprs/table_function/vexplode_bitmap.h | 4 +-
.../exprs/table_function/vexplode_json_object.cpp | 4 +-
be/src/exprs/table_function/vexplode_json_object.h | 4 +-
be/src/exprs/table_function/vexplode_map.cpp | 4 +-
be/src/exprs/table_function/vexplode_map.h | 4 +-
be/src/exprs/table_function/vexplode_numbers.cpp | 4 +-
be/src/exprs/table_function/vexplode_numbers.h | 4 +-
be/src/exprs/table_function/vexplode_v2.cpp | 4 +-
be/src/exprs/table_function/vexplode_v2.h | 8 +-
be/src/exprs/varray_literal.cpp | 6 +-
be/src/exprs/varray_literal.h | 2 -
be/src/exprs/vbitmap_predicate.cpp | 24 +-
be/src/exprs/vbitmap_predicate.h | 6 +-
be/src/exprs/vbloom_predicate.cpp | 4 +-
be/src/exprs/vbloom_predicate.h | 6 +-
be/src/exprs/vcase_expr.cpp | 4 +-
be/src/exprs/vcase_expr.h | 6 +-
be/src/exprs/vcast_expr.cpp | 4 +-
be/src/exprs/vcast_expr.h | 6 +-
be/src/exprs/vcolumn_ref.h | 2 -
be/src/exprs/vcompound_pred.h | 4 +-
be/src/exprs/vcondition_expr.cpp | 4 +-
be/src/exprs/vcondition_expr.h | 4 +-
be/src/exprs/vdirect_in_predicate.h | 4 +-
be/src/exprs/vectorized_agg_fn.cpp | 8 +-
be/src/exprs/vectorized_agg_fn.h | 5 +-
be/src/exprs/vectorized_fn_call.cpp | 4 +-
be/src/exprs/vectorized_fn_call.h | 4 +-
be/src/exprs/vexpr.cpp | 12 +-
be/src/exprs/vexpr.h | 17 +-
be/src/exprs/vexpr_context.cpp | 11 +-
be/src/exprs/vexpr_context.h | 59 +-
be/src/exprs/vexpr_fwd.h | 4 +-
be/src/exprs/vin_predicate.cpp | 4 +-
be/src/exprs/vin_predicate.h | 6 +-
be/src/exprs/vinfo_func.cpp | 4 +-
be/src/exprs/vinfo_func.h | 2 -
be/src/exprs/virtual_slot_ref.cpp | 4 +-
be/src/exprs/virtual_slot_ref.h | 4 +-
be/src/exprs/vlambda_function_call_expr.h | 4 +-
be/src/exprs/vlambda_function_expr.h | 4 +-
be/src/exprs/vliteral.cpp | 8 +-
be/src/exprs/vliteral.h | 2 -
be/src/exprs/vmap_literal.cpp | 6 +-
be/src/exprs/vmap_literal.h | 3 -
be/src/exprs/vmatch_predicate.cpp | 4 +-
be/src/exprs/vmatch_predicate.h | 6 +-
be/src/exprs/vruntimefilter_wrapper.cpp | 4 +-
be/src/exprs/vruntimefilter_wrapper.h | 4 +-
be/src/exprs/vsearch.cpp | 8 +-
be/src/exprs/vsearch.h | 4 +-
be/src/exprs/vslot_ref.cpp | 4 +-
be/src/exprs/vslot_ref.h | 2 -
be/src/exprs/vstruct_literal.cpp | 6 +-
be/src/exprs/vstruct_literal.h | 2 -
be/src/exprs/vtopn_pred.h | 13 +-
be/src/format/arrow/arrow_block_convertor.cpp | 14 +-
be/src/format/arrow/arrow_block_convertor.h | 31 +-
be/src/format/arrow/arrow_pip_input_stream.cpp | 4 +-
be/src/format/arrow/arrow_pip_input_stream.h | 2 -
be/src/format/arrow/arrow_row_batch.cpp | 16 +-
be/src/format/arrow/arrow_row_batch.h | 9 +-
be/src/format/arrow/arrow_stream_reader.cpp | 7 +-
be/src/format/arrow/arrow_stream_reader.h | 4 +-
be/src/format/avro/avro_jni_reader.cpp | 4 +-
be/src/format/avro/avro_jni_reader.h | 6 +-
be/src/format/column_type_convert.cpp | 4 +-
be/src/format/column_type_convert.h | 27 +-
be/src/format/csv/csv_reader.cpp | 8 +-
be/src/format/csv/csv_reader.h | 6 +-
be/src/format/format_common.h | 4 +-
be/src/format/generic_reader.h | 4 +-
be/src/format/jni_reader.cpp | 6 +-
be/src/format/jni_reader.h | 6 +-
be/src/format/json/new_json_reader.cpp | 14 +-
be/src/format/json/new_json_reader.h | 19 +-
be/src/format/native/native_format.h | 4 +-
be/src/format/native/native_reader.cpp | 4 +-
be/src/format/native/native_reader.h | 4 +-
be/src/format/orc/orc_file_reader.cpp | 2 -
be/src/format/orc/orc_file_reader.h | 2 -
be/src/format/orc/orc_memory_pool.h | 4 +-
be/src/format/orc/vorc_reader.cpp | 8 +-
be/src/format/orc/vorc_reader.h | 6 +-
be/src/format/parquet/arrow_memory_pool.cpp | 4 +-
be/src/format/parquet/arrow_memory_pool.h | 4 +-
be/src/format/parquet/bool_plain_decoder.cpp | 4 +-
be/src/format/parquet/bool_plain_decoder.h | 6 +-
be/src/format/parquet/bool_rle_decoder.cpp | 4 +-
be/src/format/parquet/bool_rle_decoder.h | 6 +-
be/src/format/parquet/byte_array_dict_decoder.cpp | 4 +-
be/src/format/parquet/byte_array_dict_decoder.h | 4 +-
be/src/format/parquet/byte_array_plain_decoder.cpp | 4 +-
be/src/format/parquet/byte_array_plain_decoder.h | 6 +-
.../format/parquet/byte_stream_split_decoder.cpp | 4 +-
be/src/format/parquet/byte_stream_split_decoder.h | 4 +-
be/src/format/parquet/decoder.cpp | 4 +-
be/src/format/parquet/decoder.h | 4 +-
be/src/format/parquet/delta_bit_pack_decoder.cpp | 4 +-
be/src/format/parquet/delta_bit_pack_decoder.h | 8 +-
be/src/format/parquet/fix_length_dict_decoder.hpp | 4 +-
be/src/format/parquet/fix_length_plain_decoder.cpp | 4 +-
be/src/format/parquet/fix_length_plain_decoder.h | 8 +-
be/src/format/parquet/level_decoder.cpp | 13 +-
be/src/format/parquet/level_decoder.h | 4 +-
.../parquet/parquet_block_split_bloom_filter.cpp | 2 -
.../parquet/parquet_block_split_bloom_filter.h | 2 -
be/src/format/parquet/parquet_column_convert.cpp | 4 +-
be/src/format/parquet/parquet_column_convert.h | 18 +-
be/src/format/parquet/parquet_common.cpp | 4 +-
be/src/format/parquet/parquet_common.h | 4 +-
be/src/format/parquet/parquet_predicate.h | 6 +-
be/src/format/parquet/parquet_thrift_util.h | 4 +-
be/src/format/parquet/schema_desc.cpp | 4 +-
be/src/format/parquet/schema_desc.h | 4 +-
.../parquet/vparquet_column_chunk_reader.cpp | 4 +-
.../format/parquet/vparquet_column_chunk_reader.h | 4 +-
be/src/format/parquet/vparquet_column_reader.cpp | 18 +-
be/src/format/parquet/vparquet_column_reader.h | 6 +-
be/src/format/parquet/vparquet_file_metadata.cpp | 4 +-
be/src/format/parquet/vparquet_file_metadata.h | 4 +-
be/src/format/parquet/vparquet_group_reader.cpp | 8 +-
be/src/format/parquet/vparquet_group_reader.h | 6 +-
be/src/format/parquet/vparquet_page_index.cpp | 6 +-
be/src/format/parquet/vparquet_page_index.h | 6 +-
be/src/format/parquet/vparquet_page_reader.cpp | 4 +-
be/src/format/parquet/vparquet_page_reader.h | 4 +-
be/src/format/parquet/vparquet_reader.cpp | 9 +-
be/src/format/parquet/vparquet_reader.h | 6 +-
be/src/format/table/deletion_vector_reader.cpp | 2 -
be/src/format/table/deletion_vector_reader.h | 2 -
be/src/format/table/equality_delete.cpp | 4 +-
be/src/format/table/equality_delete.h | 4 +-
.../table/hive/hive_orc_nested_column_utils.cpp | 4 +-
.../table/hive/hive_orc_nested_column_utils.h | 4 +-
.../hive/hive_parquet_nested_column_utils.cpp | 4 +-
.../table/hive/hive_parquet_nested_column_utils.h | 4 +-
be/src/format/table/hive_reader.cpp | 4 +-
be/src/format/table/hive_reader.h | 4 +-
be/src/format/table/hudi_jni_reader.cpp | 6 +-
be/src/format/table/hudi_jni_reader.h | 6 +-
be/src/format/table/hudi_reader.cpp | 4 +-
be/src/format/table/hudi_reader.h | 4 +-
.../iceberg/iceberg_orc_nested_column_utils.cpp | 4 +-
.../iceberg/iceberg_orc_nested_column_utils.h | 4 +-
.../iceberg_parquet_nested_column_utils.cpp | 4 +-
.../iceberg/iceberg_parquet_nested_column_utils.h | 4 +-
be/src/format/table/iceberg_reader.cpp | 6 +-
be/src/format/table/iceberg_reader.h | 2 -
.../format/table/iceberg_sys_table_jni_reader.cpp | 4 +-
be/src/format/table/iceberg_sys_table_jni_reader.h | 6 +-
be/src/format/table/lakesoul_jni_reader.cpp | 6 +-
be/src/format/table/lakesoul_jni_reader.h | 6 +-
be/src/format/table/max_compute_jni_reader.cpp | 6 +-
be/src/format/table/max_compute_jni_reader.h | 6 +-
be/src/format/table/nested_column_access_helper.h | 4 +-
be/src/format/table/paimon_cpp_reader.cpp | 7 +-
be/src/format/table/paimon_cpp_reader.h | 4 +-
be/src/format/table/paimon_doris_file_system.cpp | 4 +-
be/src/format/table/paimon_doris_file_system.h | 4 +-
be/src/format/table/paimon_jni_reader.cpp | 6 +-
be/src/format/table/paimon_jni_reader.h | 6 +-
be/src/format/table/paimon_predicate_converter.cpp | 4 +-
be/src/format/table/paimon_predicate_converter.h | 4 +-
be/src/format/table/paimon_reader.cpp | 4 +-
be/src/format/table/paimon_reader.h | 4 +-
be/src/format/table/parquet_metadata_reader.cpp | 4 +-
be/src/format/table/parquet_metadata_reader.h | 4 +-
be/src/format/table/parquet_utils.cpp | 4 +-
be/src/format/table/parquet_utils.h | 4 +-
be/src/format/table/remote_doris_reader.cpp | 8 +-
be/src/format/table/remote_doris_reader.h | 6 +-
be/src/format/table/table_format_reader.cpp | 4 +-
be/src/format/table/table_format_reader.h | 6 +-
be/src/format/table/transactional_hive_common.cpp | 4 +-
be/src/format/table/transactional_hive_common.h | 4 +-
be/src/format/table/transactional_hive_reader.cpp | 6 +-
be/src/format/table/transactional_hive_reader.h | 4 +-
be/src/format/table/trino_connector_jni_reader.cpp | 6 +-
be/src/format/table/trino_connector_jni_reader.h | 6 +-
be/src/format/text/text_reader.cpp | 4 +-
be/src/format/text/text_reader.h | 4 +-
be/src/format/transformer/vcsv_transformer.cpp | 4 +-
be/src/format/transformer/vcsv_transformer.h | 4 +-
.../format/transformer/vfile_format_transformer.h | 10 +-
.../vfile_format_transformer_factory.cpp | 4 +-
.../transformer/vfile_format_transformer_factory.h | 4 +-
.../format/transformer/vjni_format_transformer.cpp | 4 +-
.../format/transformer/vjni_format_transformer.h | 4 +-
be/src/format/transformer/vnative_transformer.cpp | 4 +-
be/src/format/transformer/vnative_transformer.h | 4 +-
be/src/format/transformer/vorc_transformer.cpp | 16 +-
be/src/format/transformer/vorc_transformer.h | 6 +-
be/src/format/transformer/vparquet_transformer.cpp | 4 +-
be/src/format/transformer/vparquet_transformer.h | 4 +-
.../schema_active_queries_scanner.cpp | 14 +-
.../schema_active_queries_scanner.h | 6 +-
.../schema_backend_active_tasks.cpp | 15 +-
.../schema_backend_active_tasks.h | 6 +-
.../schema_backend_configuration_scanner.cpp | 3 +-
.../schema_backend_configuration_scanner.h | 4 +-
.../schema_backend_kerberos_ticket_cache.cpp | 15 +-
.../schema_backend_kerberos_ticket_cache.h | 6 +-
.../schema_catalog_meta_cache_stats_scanner.cpp | 15 +-
.../schema_catalog_meta_cache_stats_scanner.h | 6 +-
.../information_schema/schema_charsets_scanner.cpp | 6 +-
.../information_schema/schema_charsets_scanner.h | 6 +-
.../schema_cluster_snapshot_properties_scanner.cpp | 7 +-
.../schema_cluster_snapshot_properties_scanner.h | 6 +-
.../schema_cluster_snapshots_scanner.cpp | 6 +-
.../schema_cluster_snapshots_scanner.h | 6 +-
.../schema_collations_scanner.cpp | 6 +-
.../information_schema/schema_collations_scanner.h | 6 +-
.../schema_column_data_sizes_scanner.cpp | 6 +-
.../schema_column_data_sizes_scanner.h | 6 +-
.../information_schema/schema_columns_scanner.cpp | 6 +-
be/src/information_schema/schema_columns_scanner.h | 6 +-
.../schema_database_properties_scanner.cpp | 15 +-
.../schema_database_properties_scanner.h | 6 +-
be/src/information_schema/schema_dummy_scanner.cpp | 4 +-
be/src/information_schema/schema_dummy_scanner.h | 4 +-
.../schema_encryption_keys_scanner.cpp | 6 +-
.../schema_encryption_keys_scanner.h | 6 +-
.../schema_file_cache_info_scanner.cpp | 4 +-
.../schema_file_cache_info_scanner.h | 6 +-
.../schema_file_cache_statistics.cpp | 15 +-
.../schema_file_cache_statistics.h | 6 +-
be/src/information_schema/schema_files_scanner.cpp | 4 +-
be/src/information_schema/schema_files_scanner.h | 4 +-
.../information_schema/schema_load_job_scanner.cpp | 6 +-
.../information_schema/schema_load_job_scanner.h | 6 +-
.../schema_metadata_name_ids_scanner.cpp | 6 +-
.../schema_metadata_name_ids_scanner.h | 6 +-
.../schema_partitions_scanner.cpp | 16 +-
.../information_schema/schema_partitions_scanner.h | 6 +-
.../schema_processlist_scanner.cpp | 4 +-
.../schema_processlist_scanner.h | 6 +-
.../schema_profiling_scanner.cpp | 4 +-
.../information_schema/schema_profiling_scanner.h | 4 +-
.../schema_routine_load_job_scanner.cpp | 6 +-
.../schema_routine_load_job_scanner.h | 6 +-
.../information_schema/schema_rowsets_scanner.cpp | 6 +-
be/src/information_schema/schema_rowsets_scanner.h | 6 +-
be/src/information_schema/schema_scanner.cpp | 91 ++-
be/src/information_schema/schema_scanner.h | 22 +-
.../information_schema/schema_scanner_helper.cpp | 77 ++-
be/src/information_schema/schema_scanner_helper.h | 18 +-
.../schema_schema_privileges_scanner.cpp | 6 +-
.../schema_schema_privileges_scanner.h | 6 +-
.../information_schema/schema_schemata_scanner.cpp | 6 +-
.../information_schema/schema_schemata_scanner.h | 6 +-
.../schema_sql_block_rule_status_scanner.cpp | 11 +-
.../schema_sql_block_rule_status_scanner.h | 6 +-
.../schema_table_options_scanner.cpp | 14 +-
.../schema_table_options_scanner.h | 6 +-
.../schema_table_privileges_scanner.cpp | 6 +-
.../schema_table_privileges_scanner.h | 6 +-
.../schema_table_properties_scanner.cpp | 14 +-
.../schema_table_properties_scanner.h | 6 +-
.../information_schema/schema_tables_scanner.cpp | 6 +-
be/src/information_schema/schema_tables_scanner.h | 6 +-
.../information_schema/schema_tablets_scanner.cpp | 6 +-
be/src/information_schema/schema_tablets_scanner.h | 6 +-
.../schema_user_privileges_scanner.cpp | 6 +-
.../schema_user_privileges_scanner.h | 6 +-
be/src/information_schema/schema_user_scanner.cpp | 4 +-
be/src/information_schema/schema_user_scanner.h | 6 +-
.../schema_variables_scanner.cpp | 6 +-
.../information_schema/schema_variables_scanner.h | 6 +-
.../schema_view_dependency_scanner.cpp | 12 +-
.../schema_view_dependency_scanner.h | 6 +-
be/src/information_schema/schema_views_scanner.cpp | 6 +-
be/src/information_schema/schema_views_scanner.h | 6 +-
.../schema_workload_group_privileges.cpp | 13 +-
.../schema_workload_group_privileges.h | 6 +-
...chema_workload_group_resource_usage_scanner.cpp | 15 +-
.../schema_workload_group_resource_usage_scanner.h | 6 +-
.../schema_workload_groups_scanner.cpp | 14 +-
.../schema_workload_groups_scanner.h | 6 +-
.../schema_workload_sched_policy_scanner.cpp | 15 +-
.../schema_workload_sched_policy_scanner.h | 6 +-
be/src/io/cache/block_file_cache_factory.cpp | 2 +-
be/src/io/cache/block_file_cache_factory.h | 4 +-
be/src/io/cache/file_cache_common.cpp | 2 +-
be/src/io/cache/file_cache_common.h | 2 +-
be/src/io/cache/fs_file_cache_storage.cpp | 6 +-
be/src/load/channel/load_stream_writer.h | 2 -
be/src/load/channel/tablets_channel.cpp | 2 +-
be/src/load/delta_writer/delta_writer.cpp | 2 +-
be/src/load/delta_writer/delta_writer.h | 6 +-
be/src/load/delta_writer/delta_writer_v2.cpp | 2 +-
be/src/load/delta_writer/delta_writer_v2.h | 4 +-
be/src/load/delta_writer/push_handler.cpp | 68 +--
be/src/load/delta_writer/push_handler.h | 24 +-
be/src/load/group_commit/group_commit_mgr.cpp | 32 +-
be/src/load/group_commit/group_commit_mgr.h | 47 +-
be/src/load/group_commit/wal/wal_reader.cpp | 12 +-
be/src/load/group_commit/wal/wal_reader.h | 4 +-
be/src/load/memtable/memtable.cpp | 96 ++--
be/src/load/memtable/memtable.h | 39 +-
be/src/load/memtable/memtable_flush_executor.cpp | 2 +-
be/src/load/memtable/memtable_writer.cpp | 3 +-
be/src/load/memtable/memtable_writer.h | 4 +-
be/src/runtime/descriptors.cpp | 16 +-
be/src/runtime/descriptors.h | 8 +-
be/src/runtime/exec_env.h | 37 +-
be/src/runtime/exec_env_init.cpp | 21 +-
be/src/runtime/fold_constant_executor.cpp | 30 +-
be/src/runtime/fold_constant_executor.h | 7 +-
be/src/runtime/fragment_mgr.cpp | 23 +-
be/src/runtime/fragment_mgr.h | 9 +-
be/src/runtime/query_cache/query_cache.cpp | 5 +-
be/src/runtime/query_cache/query_cache.h | 2 +-
be/src/runtime/query_context.cpp | 17 +-
be/src/runtime/query_context.h | 39 +-
be/src/runtime/record_batch_queue.h | 6 +-
be/src/runtime/result_block_buffer.cpp | 16 +-
be/src/runtime/result_block_buffer.h | 12 +-
be/src/runtime/result_buffer_mgr.cpp | 12 +-
be/src/runtime/result_buffer_mgr.h | 2 -
be/src/runtime/runtime_predicate.cpp | 4 +-
be/src/runtime/runtime_predicate.h | 9 +-
be/src/runtime/runtime_query_statistics_mgr.cpp | 2 +-
be/src/runtime/runtime_query_statistics_mgr.h | 4 +-
be/src/runtime/runtime_state.cpp | 10 +-
be/src/runtime/runtime_state.h | 10 +-
be/src/runtime/workload_group/workload_group.cpp | 51 +-
be/src/runtime/workload_group/workload_group.h | 16 +-
.../workload_group/workload_group_manager.cpp | 2 +-
.../workload_group/workload_group_manager.h | 6 +-
.../workload_management/query_task_controller.cpp | 15 +-
.../workload_management/query_task_controller.h | 2 +-
.../runtime/workload_management/task_controller.h | 4 +-
.../arrow_flight/arrow_flight_batch_reader.cpp | 8 +-
.../arrow_flight/arrow_flight_batch_reader.h | 4 +-
be/src/service/internal_service.cpp | 63 +-
be/src/service/point_query_executor.cpp | 39 +-
be/src/service/point_query_executor.h | 16 +-
.../storage/compaction/collection_similarity.cpp | 16 +-
be/src/storage/compaction/collection_similarity.h | 4 +-
.../storage/compaction/collection_statistics.cpp | 25 +-
be/src/storage/compaction/collection_statistics.h | 5 +-
be/src/storage/compaction/compaction.cpp | 18 +-
be/src/storage/delete/delete_bitmap_calculator.cpp | 6 +-
be/src/storage/delete/delete_bitmap_calculator.h | 6 +-
be/src/storage/delete/delete_handler.cpp | 95 ++--
be/src/storage/delete/delete_handler.h | 2 +-
be/src/storage/field.h | 124 ++--
be/src/storage/index/ann/ann_index.cpp | 8 +-
be/src/storage/index/ann/ann_index.h | 4 +-
be/src/storage/index/ann/ann_index_writer.cpp | 2 +-
be/src/storage/index/ann/ann_index_writer.h | 2 +-
.../storage/index/ann/ann_range_search_runtime.cpp | 2 +-
.../storage/index/ann/ann_range_search_runtime.h | 2 +-
be/src/storage/index/ann/ann_topn_runtime.cpp | 54 +-
be/src/storage/index/ann/ann_topn_runtime.h | 17 +-
be/src/storage/index/ann/faiss_ann_index.cpp | 26 +-
be/src/storage/index/ann/faiss_ann_index.h | 4 +-
.../bloom_filter/bloom_filter_index_reader.cpp | 4 +-
.../bloom_filter/bloom_filter_index_writer.cpp | 2 +-
.../index/bloom_filter/bloom_filter_index_writer.h | 4 +-
be/src/storage/index/index_iterator.h | 2 +-
be/src/storage/index/index_writer.cpp | 2 +-
be/src/storage/index/index_writer.h | 4 +-
be/src/storage/index/indexed_column_reader.cpp | 2 +-
be/src/storage/index/indexed_column_reader.h | 2 +-
be/src/storage/index/indexed_column_writer.h | 2 +-
.../inverted/analyzer/ik/core/AnalyzeContext.cpp | 2 +-
.../inverted/analyzer/ik/core/AnalyzeContext.h | 2 +-
.../index/inverted/analyzer/ik/core/IKArbitrator.h | 4 +-
.../index/inverted/analyzer/ik/core/IKSegmenter.h | 2 +-
.../index/inverted/analyzer/ik/core/LexemePath.cpp | 6 +-
.../index/inverted/analyzer/ik/core/LexemePath.h | 6 +-
.../index/inverted/analyzer/ik/core/QuickSortSet.h | 4 +-
.../index/inverted/inverted_index_iterator.cpp | 2 +-
.../index/inverted/inverted_index_iterator.h | 4 +-
.../storage/index/inverted/inverted_index_reader.h | 12 +-
be/src/storage/index/zone_map/zone_map_index.cpp | 48 +-
be/src/storage/index/zone_map/zone_map_index.h | 18 +-
be/src/storage/iterator/block_reader.cpp | 8 +-
be/src/storage/iterator/block_reader.h | 3 -
be/src/storage/iterator/olap_data_convertor.cpp | 110 ++--
be/src/storage/iterator/olap_data_convertor.h | 36 +-
be/src/storage/iterator/vcollect_iterator.cpp | 6 +-
be/src/storage/iterator/vcollect_iterator.h | 3 -
be/src/storage/iterator/vertical_block_reader.cpp | 6 +-
be/src/storage/iterator/vertical_block_reader.h | 2 -
.../storage/iterator/vertical_merge_iterator.cpp | 7 +-
be/src/storage/iterator/vertical_merge_iterator.h | 5 +-
be/src/storage/iterator/vgeneric_iterators.cpp | 2 -
be/src/storage/iterator/vgeneric_iterators.h | 2 -
be/src/storage/iterators.h | 28 +-
be/src/storage/key_coder.h | 9 +-
be/src/storage/merger.cpp | 25 +-
be/src/storage/merger.h | 19 +-
be/src/storage/olap_common.h | 8 +-
be/src/storage/olap_scan_common.h | 12 +-
be/src/storage/partial_update_info.cpp | 143 ++---
be/src/storage/partial_update_info.h | 69 +--
be/src/storage/predicate/accept_null_predicate.h | 32 +-
be/src/storage/predicate/bitmap_filter_predicate.h | 14 +-
.../storage/predicate/block_column_predicate.cpp | 30 +-
be/src/storage/predicate/block_column_predicate.h | 55 +-
be/src/storage/predicate/bloom_filter_predicate.h | 16 +-
be/src/storage/predicate/column_predicate.h | 24 +-
be/src/storage/predicate/comparison_predicate.h | 117 ++--
be/src/storage/predicate/in_list_predicate.h | 83 ++-
be/src/storage/predicate/like_column_predicate.cpp | 26 +-
be/src/storage/predicate/like_column_predicate.h | 25 +-
be/src/storage/predicate/null_predicate.cpp | 10 +-
be/src/storage/predicate/null_predicate.h | 22 +-
be/src/storage/predicate/predicate_creator.cpp | 4 +-
be/src/storage/predicate/predicate_creator.h | 34 +-
be/src/storage/predicate/shared_predicate.h | 22 +-
be/src/storage/row_cursor.cpp | 23 +-
be/src/storage/row_cursor.h | 4 +-
be/src/storage/rowset/beta_rowset_reader.cpp | 9 +-
be/src/storage/rowset/beta_rowset_reader.h | 6 +-
be/src/storage/rowset/beta_rowset_writer.cpp | 7 +-
be/src/storage/rowset/beta_rowset_writer.h | 9 +-
be/src/storage/rowset/beta_rowset_writer_v2.cpp | 5 +-
be/src/storage/rowset/beta_rowset_writer_v2.h | 9 +-
be/src/storage/rowset/rowset_meta.cpp | 2 +-
be/src/storage/rowset/rowset_reader.h | 6 +-
be/src/storage/rowset/rowset_reader_context.h | 14 +-
be/src/storage/rowset/rowset_writer.h | 9 +-
be/src/storage/rowset/segcompaction.cpp | 14 +-
be/src/storage/rowset/segcompaction.h | 9 +-
be/src/storage/rowset/segment_creator.cpp | 12 +-
be/src/storage/rowset/segment_creator.h | 18 +-
.../storage/rowset/vertical_beta_rowset_writer.cpp | 2 +-
.../storage/rowset/vertical_beta_rowset_writer.h | 6 +-
be/src/storage/rowset_builder.h | 2 -
be/src/storage/schema.cpp | 72 ++-
be/src/storage/schema.h | 23 +-
be/src/storage/schema_change/column_mapping.h | 2 +-
be/src/storage/schema_change/schema_change.cpp | 117 ++--
be/src/storage/schema_change/schema_change.h | 19 +-
be/src/storage/segment/binary_dict_page.cpp | 4 +-
be/src/storage/segment/binary_dict_page.h | 6 +-
be/src/storage/segment/binary_plain_page.h | 4 +-
be/src/storage/segment/binary_prefix_page.cpp | 2 +-
be/src/storage/segment/binary_prefix_page.h | 2 +-
be/src/storage/segment/bitshuffle_page.h | 14 +-
be/src/storage/segment/column_reader.cpp | 166 +++---
be/src/storage/segment/column_reader.h | 67 ++-
be/src/storage/segment/column_reader_cache.cpp | 3 +-
be/src/storage/segment/column_reader_cache.h | 4 +-
be/src/storage/segment/column_writer.cpp | 69 ++-
be/src/storage/segment/column_writer.h | 28 +-
be/src/storage/segment/empty_segment_iterator.cpp | 4 +-
be/src/storage/segment/empty_segment_iterator.h | 4 +-
be/src/storage/segment/frame_of_reference_page.h | 4 +-
.../storage/segment/lazy_init_segment_iterator.h | 2 -
be/src/storage/segment/page_decoder.h | 6 +-
be/src/storage/segment/plain_page.h | 4 +-
be/src/storage/segment/rle_page.h | 4 +-
be/src/storage/segment/segment.cpp | 35 +-
be/src/storage/segment/segment.h | 17 +-
be/src/storage/segment/segment_iterator.cpp | 174 +++---
be/src/storage/segment/segment_iterator.h | 81 ++-
be/src/storage/segment/segment_writer.cpp | 63 +-
be/src/storage/segment/segment_writer.h | 34 +-
be/src/storage/segment/stream_reader.cpp | 5 +-
be/src/storage/segment/stream_reader.h | 16 +-
.../variant/binary_column_extract_iterator.h | 39 +-
.../segment/variant/binary_column_reader.cpp | 14 +-
.../storage/segment/variant/binary_column_reader.h | 8 +-
.../segment/variant/hierarchical_data_iterator.cpp | 57 +-
.../segment/variant/hierarchical_data_iterator.h | 35 +-
.../segment/variant/nested_group_provider.cpp | 18 +-
.../segment/variant/nested_group_provider.h | 18 +-
.../segment/variant/nested_group_routing_plan.cpp | 14 +-
.../segment/variant/nested_group_routing_plan.h | 9 +-
.../variant/sparse_column_merge_iterator.cpp | 41 +-
.../segment/variant/sparse_column_merge_iterator.h | 15 +-
.../segment/variant/variant_column_reader.cpp | 218 ++++---
.../segment/variant/variant_column_reader.h | 72 ++-
.../segment/variant/variant_column_writer_impl.cpp | 339 ++++++-----
.../segment/variant/variant_column_writer_impl.h | 77 ++-
.../variant_doc_snpashot_compact_iterator.h | 20 +-
.../segment/variant/variant_ext_meta_writer.cpp | 4 +-
.../variant/variant_external_meta_reader.cpp | 20 +-
.../storage/segment/variant_stats_calculator.cpp | 12 +-
be/src/storage/segment/variant_stats_calculator.h | 7 +-
be/src/storage/segment/vertical_segment_writer.cpp | 88 ++-
be/src/storage/segment/vertical_segment_writer.h | 48 +-
be/src/storage/segment/virtual_column_iterator.cpp | 26 +-
be/src/storage/segment/virtual_column_iterator.h | 12 +-
be/src/storage/tablet/base_tablet.cpp | 77 ++-
be/src/storage/tablet/base_tablet.h | 19 +-
be/src/storage/tablet/tablet.cpp | 2 -
be/src/storage/tablet/tablet.h | 2 -
be/src/storage/tablet/tablet_reader.cpp | 15 +-
be/src/storage/tablet/tablet_reader.h | 24 +-
be/src/storage/tablet/tablet_schema.cpp | 62 +-
be/src/storage/tablet/tablet_schema.h | 35 +-
be/src/storage/tablet_info.cpp | 29 +-
be/src/storage/tablet_info.h | 30 +-
be/src/storage/task/engine_checksum_task.cpp | 4 +-
be/src/storage/task/index_builder.cpp | 20 +-
be/src/storage/task/index_builder.h | 13 +-
be/src/storage/types.h | 25 +-
be/src/tools/meta_tool.cpp | 6 +-
be/src/udf/python/python_udf_meta.cpp | 3 +-
be/src/udf/python/python_udf_meta.h | 7 +-
be/src/util/counts.h | 12 +-
be/src/util/io_helper.cpp | 4 +-
be/src/util/io_helper.h | 4 +-
be/src/util/json/json_parser.cpp | 4 +-
be/src/util/json/json_parser.h | 4 +-
be/src/util/json/path_in_data.cpp | 4 +-
be/src/util/json/path_in_data.h | 16 +-
be/src/util/json/simd_json_parser.h | 4 +-
be/src/util/jsonb/serialize.cpp | 4 +-
be/src/util/jsonb/serialize.h | 4 +-
be/src/util/jsonb_document.h | 15 +-
be/src/util/jsonb_document_cast.h | 38 +-
be/src/util/jsonb_utils.cpp | 20 +-
be/src/util/jsonb_utils.h | 8 +-
be/src/util/jsonb_writer.h | 6 +-
be/src/util/reservoir_sampler.h | 6 +-
be/src/util/s3_util.h | 1 +
be/src/util/simd/reverse_copy_bytes.h | 6 +-
be/src/util/string_parser.cpp | 8 +-
be/src/util/string_parser.hpp | 6 +-
be/src/util/timezone_utils.cpp | 4 +-
be/src/util/var_int.h | 4 +-
be/test/ai/aggregate_function_ai_agg_test.cpp | 4 +-
be/test/ai/ai_adapter_test.cpp | 8 +-
be/test/ai/ai_function_test.cpp | 4 +-
be/test/ai/embed_test.cpp | 4 +-
be/test/common/check_overflow.cpp | 4 +-
be/test/core/accurate_comparison_test.cpp | 4 +-
be/test/core/block/block_test.cpp | 617 ++++++++++----------
be/test/core/block/column_array_test.cpp | 4 +-
be/test/core/block/column_complex_test.cpp | 6 +-
be/test/core/block/column_map_test.cpp | 4 +-
be/test/core/block/column_nullable_test.cpp | 4 +-
be/test/core/block/column_struct_test.cpp | 4 +-
be/test/core/block/column_test.cpp | 4 +-
be/test/core/block/column_vector_test.cpp | 4 +-
.../core/block/column_with_type_and_name_test.cpp | 4 +-
be/test/core/block/get_common_type_test.cpp | 6 +-
be/test/core/block/number_traits_test.cpp | 24 +-
.../core/column/check_and_get_column_ptr_test.cpp | 4 +-
.../check_column_with_type_and_name_test.cpp | 4 +-
be/test/core/column/column_array_test.cpp | 7 +-
be/test/core/column/column_base_test.cpp | 4 +-
.../column_check_const_only_in_top_level_test.cpp | 4 +-
be/test/core/column/column_const_test.cpp | 4 +-
be/test/core/column/column_decimal_test.cpp | 8 +-
be/test/core/column/column_dictionary_test.cpp | 4 +-
be/test/core/column/column_execute_util_test.cpp | 4 +-
.../column/column_fixed_length_object_test.cpp | 6 +-
be/test/core/column/column_hash_func_test.cpp | 65 ++-
be/test/core/column/column_ip_test.cpp | 8 +-
be/test/core/column/column_map_test.cpp | 4 +-
be/test/core/column/column_nothing_test.cpp | 4 +-
.../column/column_nullable_seriazlization_test.cpp | 2 +-
be/test/core/column/column_nullable_test.cpp | 4 +-
be/test/core/column/column_nullable_test.h | 10 +-
be/test/core/column/column_resize_test.cpp | 6 +-
be/test/core/column/column_self_check.cpp | 4 +-
be/test/core/column/column_string_test.cpp | 6 +-
be/test/core/column/column_struct_test.cpp | 4 +-
be/test/core/column/column_varbinary_test.cpp | 4 +-
be/test/core/column/column_variant_test.cpp | 203 +++----
be/test/core/column/column_vector_test.cpp | 4 +-
be/test/core/column/common_column_test.h | 8 +-
be/test/core/column/pod_array_type_test.cpp | 4 +-
be/test/core/data_type/block_check_type.cpp | 4 +-
.../core/data_type/common_data_type_serder_test.h | 4 +-
be/test/core/data_type/common_data_type_test.h | 4 +-
be/test/core/data_type/complex_type_test.cpp | 4 +-
.../core/data_type/data_type_agg_state_test.cpp | 4 +-
be/test/core/data_type/data_type_array_test.cpp | 4 +-
be/test/core/data_type/data_type_bitmap_test.cpp | 10 +-
.../core/data_type/data_type_datetime_v1_test.cpp | 4 +-
.../core/data_type/data_type_datetime_v2_test.cpp | 4 +-
be/test/core/data_type/data_type_decimal_test.cpp | 4 +-
.../data_type_fixed_length_object_test.cpp | 4 +-
be/test/core/data_type/data_type_hll_test.cpp | 10 +-
be/test/core/data_type/data_type_ip_test.cpp | 8 +-
be/test/core/data_type/data_type_jsonb_test.cpp | 4 +-
be/test/core/data_type/data_type_map_test.cpp | 10 +-
be/test/core/data_type/data_type_nothing_test.cpp | 4 +-
be/test/core/data_type/data_type_number_test.cpp | 4 +-
.../data_type/data_type_quantile_state_test.cpp | 12 +-
be/test/core/data_type/data_type_string_test.cpp | 4 +-
be/test/core/data_type/data_type_struct_test.cpp | 14 +-
.../core/data_type/data_type_timestamptz_test.cpp | 4 +-
.../core/data_type/data_type_varbinary_test.cpp | 4 +-
be/test/core/data_type/datetime_round_test.cpp | 6 +-
be/test/core/data_type/decimal_test.cpp | 60 +-
be/test/core/data_type/from_string_test.cpp | 4 +-
be/test/core/data_type/serde_utils.h | 4 +-
.../data_type_serde/data_type_from_string_test.cpp | 4 +-
.../data_type_serde/data_type_jsonb_serde_test.cpp | 4 +-
.../data_type_serde_agg_state_test.cpp | 4 +-
.../data_type_serde/data_type_serde_arrow_test.cpp | 128 ++---
.../data_type_serde_bitmap_test.cpp | 16 +-
.../data_type_serde/data_type_serde_csv_test.cpp | 4 +-
.../data_type_serde_datetime_v1_test.cpp | 4 +-
.../data_type_serde_datetime_v2_test.cpp | 4 +-
.../data_type_serde_decimal_test.cpp | 4 +-
.../data_type_serde_fixed_length_object_test.cpp | 24 +-
.../data_type_serde_get_name_test.cpp | 4 +-
.../data_type_serde/data_type_serde_hll_test.cpp | 16 +-
.../data_type_serde/data_type_serde_map_test.cpp | 4 +-
.../data_type_serde/data_type_serde_mysql_test.cpp | 105 ++--
.../data_type_serde_number_test.cpp | 4 +-
.../data_type_serde/data_type_serde_pb_test.cpp | 201 +++----
.../data_type_serde_quantile_state_test.cpp | 12 +-
.../data_type_serde_string_test.cpp | 4 +-
.../data_type_serde_struct_test.cpp | 4 +-
.../core/data_type_serde/data_type_serde_test.cpp | 61 +-
.../data_type_serde/data_type_serde_text_test.cpp | 4 +-
.../data_type_serde_timestamptz_test.cpp | 4 +-
.../data_type_serde_varbinary_test.cpp | 4 +-
.../data_type_serde/data_type_to_string_test.cpp | 4 +-
.../data_type_write_to_jsonb_test.cpp | 4 +-
be/test/core/field_test.cpp | 4 +-
be/test/core/jsonb/convert_field_to_type_test.cpp | 4 +-
be/test/core/jsonb/json_parser_test.cpp | 41 +-
be/test/core/jsonb/jsonb_document_cast_test.cpp | 4 +-
be/test/core/jsonb/jsonb_document_test.cpp | 8 +-
be/test/core/jsonb/path_in_data_test.cpp | 4 +-
be/test/core/jsonb/serialize_test.cpp | 165 +++---
be/test/core/pod_array_test.cpp | 69 ++-
be/test/core/string_buffer_test.cpp | 4 +-
.../utils/arrow_column_to_doris_column_test.cpp | 40 +-
be/test/core/utils/histogram_helpers_test.cpp | 4 +-
be/test/core/utils/small_size_hash_set_test.cpp | 4 +-
be/test/core/utils/stringop_substring_test.cpp | 4 +-
be/test/core/value/bitmap_value_test.cpp | 2 +-
be/test/core/value/ip_value_test.cpp | 4 +-
be/test/core/value/jsonb_value_test2.cpp | 22 +-
be/test/core/value/sort_merger_test.cpp | 187 +++---
be/test/core/value/vdatetime_value_test.cpp | 4 +-
be/test/core/wide_integer_test.cpp | 4 +-
be/test/exec/agg/agg_fn_evaluator_test.cpp | 24 +-
be/test/exec/column_type_convert_test.cpp | 135 ++---
be/test/exec/common/schema_util_rowset_test.cpp | 18 +-
be/test/exec/common/schema_util_test.cpp | 220 ++++---
be/test/exec/common/string_utils_test.cpp | 4 +-
be/test/exec/concurrent_queue_order.cpp | 4 +-
be/test/exec/connector/vjdbc_connector_test.cpp | 4 +-
.../dictionary/dictionary_get_nullable_test.cpp | 4 +-
.../exec/dictionary/dictionary_ip_trie_test.cpp | 4 +-
be/test/exec/dictionary/dictionary_status_test.cpp | 4 +-
be/test/exec/dictionary/dictionary_util_test.cpp | 4 +-
.../exec/dictionary/dictionary_version_test.cpp | 4 +-
be/test/exec/exchange/exchange_sink_test.cpp | 14 +-
be/test/exec/exchange/exchange_sink_test.h | 33 +-
be/test/exec/exchange/exchange_writer_test.cpp | 28 +-
.../split_concurrency_controller_test.cpp | 4 +-
.../time_sharing_task_executor_test.cpp | 2 -
be/test/exec/hash_map/hash_table_method_test.cpp | 4 +-
.../agg_operator_group_by_limit_opt_test.cpp | 193 +++----
be/test/exec/operator/agg_operator_test.cpp | 199 +++----
be/test/exec/operator/agg_shared_state_test.cpp | 24 +-
.../exec/operator/analytic_sink_operator_test.cpp | 71 ++-
.../exec/operator/assert_nums_rows_operator.cpp | 7 +-
be/test/exec/operator/datagen_operator_test.cpp | 16 +-
...istinct_streaming_aggregation_operator_test.cpp | 5 +-
be/test/exec/operator/empty_set_operator_test.cpp | 6 +-
.../exec/operator/exchange_sink_operator_test.cpp | 7 +-
.../operator/exchange_source_operator_test.cpp | 6 +-
be/test/exec/operator/hash_join_test_helper.cpp | 4 +-
be/test/exec/operator/hash_join_test_helper.h | 4 +-
be/test/exec/operator/hashjoin_build_sink_test.cpp | 16 +-
.../exec/operator/hashjoin_probe_operator_test.cpp | 453 +++++++--------
be/test/exec/operator/join_test_helper.cpp | 4 +-
be/test/exec/operator/join_test_helper.h | 4 +-
.../local_merge_sort_source_operator_test.cpp | 10 +-
.../operator/materialization_shared_state_test.cpp | 110 ++--
be/test/exec/operator/operator_helper.h | 4 +-
.../operator/partition_sort_sink_operator_test.cpp | 94 ++-
.../partitioned_aggregation_sink_operator_test.cpp | 79 ++-
...artitioned_aggregation_source_operator_test.cpp | 42 +-
.../partitioned_aggregation_test_helper.cpp | 4 +-
.../operator/partitioned_aggregation_test_helper.h | 10 +-
.../partitioned_hash_join_probe_operator_test.cpp | 164 +++---
.../partitioned_hash_join_sink_operator_test.cpp | 28 +-
.../operator/partitioned_hash_join_test_helper.cpp | 4 +-
.../operator/partitioned_hash_join_test_helper.h | 20 +-
.../exec/operator/query_cache_operator_test.cpp | 19 +-
be/test/exec/operator/repeat_operator_test.cpp | 5 +-
.../operator/scan_normalize_predicate_test.cpp | 162 +++---
be/test/exec/operator/set_operator_test.cpp | 6 +-
be/test/exec/operator/sort_operator_test.cpp | 27 +-
.../operator/spill_sort_sink_operator_test.cpp | 63 +-
.../operator/spill_sort_source_operator_test.cpp | 97 ++--
be/test/exec/operator/spill_sort_test_helper.cpp | 4 +-
be/test/exec/operator/spill_sort_test_helper.h | 8 +-
.../operator/spillable_operator_test_helper.cpp | 14 +-
.../exec/operator/spillable_operator_test_helper.h | 14 +-
.../exec/operator/streaming_agg_operator_test.cpp | 74 ++-
.../exec/operator/table_function_operator_test.cpp | 47 +-
be/test/exec/operator/union_operator_test.cpp | 6 +-
be/test/exec/pipeline/common/agg_utils_test.cpp | 78 ++-
.../pipeline/common/distinct_agg_utils_test.cpp | 133 ++---
be/test/exec/pipeline/common/set_utils_test.cpp | 73 +--
be/test/exec/pipeline/data_queue_test.cpp | 6 +-
be/test/exec/pipeline/dummy_task_queue.h | 4 +-
be/test/exec/pipeline/local_exchanger_test.cpp | 162 +++---
.../pipeline/multi_cast_data_streamer_test.cpp | 16 +-
be/test/exec/pipeline/pipeline_task_test.cpp | 12 +-
be/test/exec/pipeline/pipeline_test.cpp | 33 +-
be/test/exec/pipeline/query_cache_test.cpp | 5 +-
be/test/exec/pipeline/vdata_stream_recvr_test.cpp | 5 +-
.../runtime_filter_consumer_helper_test.cpp | 33 +-
.../runtime_filter_consumer_test.cpp | 8 +-
.../runtime_filter/runtime_filter_mgr_test.cpp | 4 +-
.../runtime_filter_producer_helper_cross_test.cpp | 40 +-
.../runtime_filter_producer_helper_set_test.cpp | 36 +-
.../runtime_filter_producer_helper_test.cpp | 90 +--
.../runtime_filter_producer_test.cpp | 8 +-
.../runtime_filter/runtime_filter_wrapper_test.cpp | 118 ++--
be/test/exec/runtime_filter/utils_test.cpp | 22 +-
be/test/exec/scan/mock_simplified_scan_scheduler.h | 4 +-
be/test/exec/scan/scan_operator_test.cpp | 8 +-
be/test/exec/scan/scanner_context_test.cpp | 74 +--
be/test/exec/scan/vfile_scanner_exception_test.cpp | 28 +-
be/test/exec/scan/vgeneric_iterators_test.cpp | 58 +-
be/test/exec/scan/vhive_utils_test.cpp | 4 +-
...ma_cluster_snapshot_properties_scanner_test.cpp | 2 +-
.../schema_cluster_snapshots_scanner_test.cpp | 2 +-
.../schema_encryption_keys_scanner_test.cpp | 2 +-
.../exec/sink/arrow_result_block_buffer_test.cpp | 16 +-
be/test/exec/sink/get_result_batch_test.cpp | 4 +-
be/test/exec/sink/result_block_buffer_test.cpp | 12 +-
be/test/exec/sink/sink_test_utils.h | 7 +-
.../sink/tablet_sink_hash_partitioner_test.cpp | 10 +-
be/test/exec/sink/vrow_distribution_test.cpp | 6 +-
be/test/exec/sink/vtablet_writer_v2_test.cpp | 10 +-
.../writer/iceberg/partition_transformers_test.cpp | 22 +-
be/test/exec/skewed_partition_rebalancer_test.cpp | 4 +-
be/test/exec/sort/full_sort_test.cpp | 4 +-
be/test/exec/sort/heap_sorter_test.cpp | 4 +-
be/test/exec/sort/merge_sorter_state.cpp | 4 +-
be/test/exec/sort/partition_sorter_test.cpp | 4 +-
be/test/exec/sort/sort_test.cpp | 34 +-
be/test/exec/sort/topn_sort_test.cpp | 4 +-
be/test/exprs/aggregate/agg_array_agg_test.cpp | 6 +-
be/test/exprs/aggregate/agg_avg_test.cpp | 4 +-
be/test/exprs/aggregate/agg_bit_test.cpp | 4 +-
be/test/exprs/aggregate/agg_bitmap_test.cpp | 4 +-
be/test/exprs/aggregate/agg_bool_union_test.cpp | 4 +-
be/test/exprs/aggregate/agg_collect_test.cpp | 8 +-
be/test/exprs/aggregate/agg_corr_test.cpp | 4 +-
be/test/exprs/aggregate/agg_count_test.cpp | 4 +-
be/test/exprs/aggregate/agg_function_test.h | 30 +-
.../aggregate/agg_group_array_intersect_test.cpp | 141 +++--
be/test/exprs/aggregate/agg_histogram_test.cpp | 6 +-
.../exprs/aggregate/agg_linear_histogram_test.cpp | 6 +-
be/test/exprs/aggregate/agg_min_max_by_test.cpp | 6 +-
be/test/exprs/aggregate/agg_min_max_test.cpp | 4 +-
be/test/exprs/aggregate/agg_replace_test.cpp | 26 +-
be/test/exprs/aggregate/agg_test.cpp | 10 +-
be/test/exprs/aggregate/vec_count_by_enum_test.cpp | 46 +-
be/test/exprs/aggregate/vec_retention_test.cpp | 78 ++-
.../exprs/aggregate/vec_sequence_match_test.cpp | 86 ++-
be/test/exprs/aggregate/vec_window_funnel_test.cpp | 186 +++---
be/test/exprs/bloom_filter_func_test.cpp | 59 +-
be/test/exprs/function/cast/cast_test.h | 4 +-
be/test/exprs/function/cast/cast_to_array_test.cpp | 4 +-
.../exprs/function/cast/cast_to_boolean_test.cpp | 4 +-
be/test/exprs/function/cast/cast_to_date_test.cpp | 4 +-
.../exprs/function/cast/cast_to_datetime_test.cpp | 4 +-
be/test/exprs/function/cast/cast_to_decimal.cpp | 4 +-
.../cast/cast_to_decimal128_from_decimal128.cpp | 4 +-
...cast_to_decimal128_from_decimal128_overflow.cpp | 4 +-
.../cast/cast_to_decimal128_from_decimal256.cpp | 4 +-
...cast_to_decimal128_from_decimal256_overflow.cpp | 4 +-
.../cast/cast_to_decimal128_from_decimal32.cpp | 4 +-
.../cast_to_decimal128_from_decimal32_overflow.cpp | 4 +-
.../cast/cast_to_decimal128_from_decimal64.cpp | 4 +-
.../cast_to_decimal128_from_decimal64_overflow.cpp | 4 +-
.../cast/cast_to_decimal128_from_double.cpp | 4 +-
.../cast_to_decimal128_from_double_overflow.cpp | 4 +-
.../cast/cast_to_decimal128_from_float.cpp | 4 +-
.../cast_to_decimal128_from_float_overflow.cpp | 4 +-
.../function/cast/cast_to_decimal128_from_int.cpp | 4 +-
.../cast/cast_to_decimal128_from_int_overflow.cpp | 4 +-
.../cast/cast_to_decimal128_from_string.cpp | 4 +-
.../cast_to_decimal128_from_string_overflow.cpp | 4 +-
.../function/cast/cast_to_decimal128_perf.cpp | 4 +-
.../cast/cast_to_decimal256_from_decimal128.cpp | 4 +-
...cast_to_decimal256_from_decimal128_overflow.cpp | 4 +-
.../cast/cast_to_decimal256_from_decimal256.cpp | 4 +-
...cast_to_decimal256_from_decimal256_overflow.cpp | 4 +-
.../cast/cast_to_decimal256_from_decimal32.cpp | 4 +-
.../cast_to_decimal256_from_decimal32_overflow.cpp | 4 +-
.../cast/cast_to_decimal256_from_decimal64.cpp | 4 +-
.../cast_to_decimal256_from_decimal64_overflow.cpp | 4 +-
.../cast/cast_to_decimal256_from_double.cpp | 4 +-
.../cast_to_decimal256_from_double_overflow.cpp | 4 +-
.../cast/cast_to_decimal256_from_float.cpp | 4 +-
.../cast_to_decimal256_from_float_overflow.cpp | 4 +-
.../function/cast/cast_to_decimal256_from_int.cpp | 4 +-
.../cast/cast_to_decimal256_from_int_overflow.cpp | 4 +-
.../cast/cast_to_decimal256_from_string.cpp | 4 +-
.../cast_to_decimal256_from_string_overflow.cpp | 4 +-
.../cast/cast_to_decimal32_from_decimal128.cpp | 4 +-
.../cast_to_decimal32_from_decimal128_overflow.cpp | 4 +-
.../cast/cast_to_decimal32_from_decimal256.cpp | 4 +-
.../cast_to_decimal32_from_decimal256_overflow.cpp | 4 +-
.../cast/cast_to_decimal32_from_decimal32.cpp | 4 +-
.../cast_to_decimal32_from_decimal32_overflow.cpp | 4 +-
.../cast/cast_to_decimal32_from_decimal64.cpp | 4 +-
.../cast_to_decimal32_from_decimal64_overflow.cpp | 4 +-
.../cast/cast_to_decimal32_from_double.cpp | 4 +-
.../cast_to_decimal32_from_double_overflow.cpp | 4 +-
.../function/cast/cast_to_decimal32_from_float.cpp | 4 +-
.../cast/cast_to_decimal32_from_float_overflow.cpp | 4 +-
.../function/cast/cast_to_decimal32_from_int.cpp | 4 +-
.../cast/cast_to_decimal32_from_int_overflow.cpp | 4 +-
.../cast/cast_to_decimal32_from_string.cpp | 4 +-
.../cast_to_decimal32_from_string_overflow.cpp | 4 +-
.../cast/cast_to_decimal64_from_decimal128.cpp | 4 +-
.../cast_to_decimal64_from_decimal128_overflow.cpp | 4 +-
.../cast/cast_to_decimal64_from_decimal256.cpp | 4 +-
.../cast_to_decimal64_from_decimal256_overflow.cpp | 4 +-
.../cast/cast_to_decimal64_from_decimal32.cpp | 4 +-
.../cast_to_decimal64_from_decimal32_overflow.cpp | 4 +-
.../cast/cast_to_decimal64_from_decimal64.cpp | 4 +-
.../cast_to_decimal64_from_decimal64_overflow.cpp | 4 +-
.../cast/cast_to_decimal64_from_double.cpp | 4 +-
.../cast_to_decimal64_from_double_overflow.cpp | 4 +-
.../function/cast/cast_to_decimal64_from_float.cpp | 4 +-
.../cast/cast_to_decimal64_from_float_overflow.cpp | 4 +-
.../function/cast/cast_to_decimal64_from_int.cpp | 4 +-
.../cast/cast_to_decimal64_from_int_overflow.cpp | 4 +-
.../cast/cast_to_decimal64_from_string.cpp | 4 +-
.../cast_to_decimal64_from_string_overflow.cpp | 4 +-
be/test/exprs/function/cast/cast_to_decimal_test.h | 8 +-
.../exprs/function/cast/cast_to_float_double.cpp | 4 +-
be/test/exprs/function/cast/cast_to_integer.cpp | 4 +-
be/test/exprs/function/cast/cast_to_ip_test.cpp | 4 +-
be/test/exprs/function/cast/cast_to_map_test.cpp | 4 +-
be/test/exprs/function/cast/cast_to_string.cpp | 4 +-
.../function/cast/cast_to_string_api_test.cpp | 4 +-
.../exprs/function/cast/cast_to_struct_test.cpp | 4 +-
be/test/exprs/function/cast/cast_to_time_test.cpp | 4 +-
.../function/cast/cast_to_timestamptz_test.cpp | 4 +-
.../function/cast/function_variant_cast_test.cpp | 19 +-
.../exprs/function/function_arithmetic_test.cpp | 4 +-
.../function/function_array_aggregation_test.cpp | 4 +-
.../function_array_cosine_similarity_test.cpp | 4 +-
.../exprs/function/function_array_element_test.cpp | 4 +-
.../exprs/function/function_array_index_test.cpp | 4 +-
.../exprs/function/function_array_size_test.cpp | 4 +-
.../function/function_arrays_overlap_test.cpp | 4 +-
be/test/exprs/function/function_bitmap_test.cpp | 4 +-
...ion_comparison_evaluate_inverted_index_test.cpp | 4 +-
.../function_complex_hash_map_dict_test.cpp | 4 +-
.../function_compressed_materialization_test.cpp | 4 +-
.../exprs/function/function_dict_get_many_test.cpp | 4 +-
be/test/exprs/function/function_dict_get_test.cpp | 4 +-
.../exprs/function/function_eq_for_null_test.cpp | 44 +-
be/test/exprs/function/function_geo_test.cpp | 4 +-
.../exprs/function/function_hash_map_dict_test.cpp | 4 +-
.../exprs/function/function_hash_map_dict_test.h | 4 +-
be/test/exprs/function/function_hash_test.cpp | 4 +-
be/test/exprs/function/function_hll_test.cpp | 4 +-
be/test/exprs/function/function_ip_dict_test.cpp | 4 +-
be/test/exprs/function/function_ip_dict_test.h | 4 +-
be/test/exprs/function/function_ip_test.cpp | 4 +-
be/test/exprs/function/function_is_null_test.cpp | 24 +-
be/test/exprs/function/function_jsonb_test.cpp | 4 +-
be/test/exprs/function/function_like_test.cpp | 4 +-
be/test/exprs/function/function_map_test.cpp | 4 +-
be/test/exprs/function/function_match_test.cpp | 4 +-
be/test/exprs/function/function_math_test.cpp | 4 +-
.../exprs/function/function_money_format_test.cpp | 4 +-
.../exprs/function/function_multi_match_test.cpp | 4 +-
be/test/exprs/function/function_nullif_test.cpp | 4 +-
be/test/exprs/function/function_num_if_test.cpp | 4 +-
.../function/function_quantile_state_test.cpp | 4 +-
be/test/exprs/function/function_round_test.cpp | 4 +-
.../exprs/function/function_search_nested_test.cpp | 24 +-
be/test/exprs/function/function_search_test.cpp | 55 +-
be/test/exprs/function/function_string_test.cpp | 4 +-
.../function/function_struct_element_test.cpp | 4 +-
.../exprs/function/function_sub_replace_test.cpp | 4 +-
be/test/exprs/function/function_test_template.cpp | 4 +-
be/test/exprs/function/function_test_util.cpp | 6 +-
be/test/exprs/function/function_test_util.h | 4 +-
.../function/function_throw_exception_test.cpp | 4 +-
be/test/exprs/function/function_time_test.cpp | 4 +-
be/test/exprs/function/function_tokenize_test.cpp | 4 +-
be/test/exprs/function/function_url_test.cpp | 4 +-
be/test/exprs/function/function_uuid_test.cpp | 4 +-
be/test/exprs/function/function_varbinary_test.cpp | 4 +-
.../function/function_variant_element_test.cpp | 6 +-
.../function/simple_function_factory_test.cpp | 4 +-
be/test/exprs/function/table_function_test.cpp | 4 +-
be/test/exprs/hybrid_set_test.cpp | 42 +-
be/test/exprs/minmax_predicate_test.cpp | 22 +-
be/test/exprs/mock_vexpr.h | 9 +-
be/test/exprs/score_runtime_test.cpp | 4 +-
be/test/exprs/short_circuit_util_test.cpp | 4 +-
be/test/exprs/try_cast_expr_test.cpp | 4 +-
.../exprs/vexpr_evalute_inverted_index_test.cpp | 25 +-
be/test/exprs/vexpr_test.cpp | 20 +-
be/test/exprs/virtual_slot_ref_test.cpp | 4 +-
be/test/exprs/vsearch_expr_test.cpp | 4 +-
.../new_plain_text_line_reader_test.cpp | 4 +-
.../format/native/native_reader_writer_test.cpp | 4 +-
be/test/format/orc/orc_convert_dict_test.cpp | 3 -
.../format/orc/orc_convert_to_orc_literal_test.cpp | 2 -
be/test/format/orc/orc_file_reader_test.cpp | 2 -
be/test/format/orc/orc_memory_stream_test.h | 2 -
be/test/format/orc/orc_read_lines.cpp | 42 +-
be/test/format/orc/orc_reader_fill_data_test.cpp | 2 -
be/test/format/orc/orc_reader_init_column_test.cpp | 2 -
be/test/format/orc/orc_reader_test.cpp | 4 +-
be/test/format/parquet/bool_plain_decoder_test.cpp | 4 +-
be/test/format/parquet/bool_rle_decoder_test.cpp | 4 +-
.../parquet/byte_array_dict_decoder_test.cpp | 12 +-
.../parquet/byte_array_plain_decoder_test.cpp | 4 +-
.../parquet/byte_stream_split_decoder_test.cpp | 4 +-
.../format/parquet/delta_bit_pack_decoder_test.cpp | 4 +-
.../parquet/delta_byte_array_decoder_test.cpp | 4 +-
.../delta_length_byte_array_decoder_test.cpp | 4 +-
.../parquet/fix_length_dict_decoder_test.cpp | 12 +-
.../parquet/fix_length_plain_decoder_test.cpp | 4 +-
be/test/format/parquet/level_decoder_test.cpp | 4 +-
be/test/format/parquet/parquet_common_test.cpp | 4 +-
.../parquet/parquet_corrupt_statistics_test.cpp | 2 -
be/test/format/parquet/parquet_expr_test.cpp | 60 +-
.../parquet_nested_type_cross_page_test.cpp | 4 +-
be/test/format/parquet/parquet_page_cache_test.cpp | 2 +-
be/test/format/parquet/parquet_read_lines.cpp | 6 +-
be/test/format/parquet/parquet_reader_test.cpp | 2 -
be/test/format/parquet/parquet_statistics_test.cpp | 2 -
be/test/format/parquet/parquet_thrift_test.cpp | 18 +-
be/test/format/parquet/parquet_utils_test.cpp | 4 +-
be/test/format/parquet/parquet_version_test.cpp | 2 -
.../hive/hive_reader_create_column_ids_test.cpp | 4 +-
be/test/format/table/hive/hive_reader_test.cpp | 4 +-
.../iceberg_reader_create_column_ids_test.cpp | 4 +-
.../format/table/iceberg/iceberg_reader_test.cpp | 4 +-
be/test/format/table/paimon_cpp_reader_test.cpp | 4 +-
.../table/table_schema_change_helper_test.cpp | 129 ++---
.../format/text/hive_text_field_splitter_test.cpp | 4 +-
be/test/format/wal/wal_manager_test.cpp | 30 +-
be/test/format/wal/wal_reader_writer_test.cpp | 15 +-
be/test/gutil/strings/numbers_test.cpp | 36 +-
be/test/io/cache/need_update_lru_blocks_test.cpp | 2 +-
.../delta_writer/delta_writer_cluster_key_test.cpp | 8 +-
be/test/load/delta_writer/delta_writer_test.cpp | 28 +-
.../delta_writer/delta_writer_v2_pool_test.cpp | 4 +-
.../load/memtable/memtable_flush_executor_test.cpp | 15 -
.../load/memtable/memtable_memory_limiter_test.cpp | 6 +-
be/test/runtime/arena_test.cpp | 12 +-
be/test/runtime/result_buffer_mgr_test.cpp | 2 +-
be/test/runtime/snapshot_loader_test.cpp | 6 +-
be/test/runtime/timestamptz_value_test.cpp | 4 +-
.../workload_group/workload_group_manager_test.cpp | 12 +-
.../compaction/collection_similarity_test.cpp | 96 ++--
.../compaction/collection_statistics_test.cpp | 66 +--
.../compaction/ordered_data_compaction_test.cpp | 13 +-
.../storage/compaction/segcompaction_mow_test.cpp | 37 +-
be/test/storage/compaction/segcompaction_test.cpp | 61 +-
.../variant_doc_mode_compaction_test.cpp | 9 +-
.../compaction/vertical_compaction_test.cpp | 23 +-
.../storage/index/ann/ann_index_edge_case_test.cpp | 4 +-
.../storage/index/ann/ann_index_iterator_test.cpp | 6 +-
.../storage/index/ann/ann_index_reader_test.cpp | 4 +-
be/test/storage/index/ann/ann_index_smoke_test.cpp | 2 +-
.../storage/index/ann/ann_index_writer_test.cpp | 6 +-
.../storage/index/ann/ann_range_search_test.cpp | 40 +-
.../storage/index/ann/ann_topn_descriptor_test.cpp | 24 +-
.../index/ann/ann_topn_runtime_negative_test.cpp | 6 +-
.../storage/index/ann/faiss_vector_index_test.cpp | 4 +-
be/test/storage/index/ann/vector_search_utils.h | 6 +-
.../index/ann/virtual_column_iterator_test.cpp | 83 ++-
be/test/storage/index/date_bloom_filter_test.cpp | 6 +-
be/test/storage/index/index_builder_test.cpp | 109 ++--
.../index/inverted/analyzer/ik_anayzer_test.cpp | 2 +-
.../common/inverted_index_gc_binlogs_test.cpp | 6 +-
.../index_compaction_performance_test.cpp | 2 +-
.../inverted/compaction/index_compaction_test.cpp | 2 +-
.../compaction/util/index_compaction_utils.cpp | 27 +-
.../inverted/query/phrase_edge_query_test.cpp | 4 +-
.../inverted/query/phrase_prefix_query_test.cpp | 4 +-
.../index/inverted/query/phrase_query_test.cpp | 4 +-
.../inverted/query_v2/phrase_prefix_query_test.cpp | 9 +-
be/test/storage/index/primary_key_index_test.cpp | 2 +-
.../iterator/vertical_merge_iterator_test.cpp | 4 +-
be/test/storage/metadata_adder_test.cpp | 10 +-
be/test/storage/olap_type_test.cpp | 10 +-
.../predicate/accept_null_predicate_test.cpp | 13 +-
.../predicate/block_column_predicate_test.cpp | 631 ++++++++++-----------
be/test/storage/row_cursor_test.cpp | 4 +-
be/test/storage/rowid_conversion_test.cpp | 4 +-
be/test/storage/segment/binary_dict_page_test.cpp | 28 +-
be/test/storage/segment/binary_plain_page_test.cpp | 2 +-
.../storage/segment/binary_plain_page_v2_test.cpp | 18 +-
.../storage/segment/binary_prefix_page_test.cpp | 14 +-
be/test/storage/segment/bitshuffle_page_test.cpp | 4 +-
.../storage/segment/block_bloom_filter_test.cpp | 2 +-
.../storage/segment/column_reader_cache_test.cpp | 10 +-
be/test/storage/segment/column_reader_test.cpp | 13 +-
.../storage/segment/column_reader_writer_test.cpp | 52 +-
.../segment/external_col_meta_util_test.cpp | 2 +-
.../segment/frame_of_reference_page_test.cpp | 4 +-
.../segment/hierarchical_data_iterator_test.cpp | 23 +-
.../storage/segment/inverted_index_array_test.cpp | 352 ++++++------
.../segment/inverted_index_file_writer_test.cpp | 2 +-
.../segment/inverted_index_iterator_test.cpp | 4 +-
.../segment/inverted_index_query_param_test.cpp | 120 ++--
.../storage/segment/inverted_index_reader_test.cpp | 18 +-
.../storage/segment/inverted_index_writer_test.cpp | 96 ++--
.../storage/segment/nested_group_provider_test.cpp | 10 +-
be/test/storage/segment/plain_page_test.cpp | 4 +-
be/test/storage/segment/rle_page_test.cpp | 4 +-
be/test/storage/segment/segment_cache_test.cpp | 8 +-
.../segment_writer_full_encode_keys_test.cpp | 6 +-
.../segments_key_bounds_truncation_test.cpp | 48 +-
.../segment/variant_column_writer_reader_test.cpp | 207 ++++---
.../segment/variant_stats_calculator_test.cpp | 107 ++--
be/test/storage/segment/variant_util_test.cpp | 80 ++-
be/test/storage/segment/zone_map_index_test.cpp | 124 ++--
be/test/storage/storage_resource_test.cpp | 9 +-
be/test/storage/storage_types_test.cpp | 8 +-
be/test/storage/tablet/tablet_cooldown_test.cpp | 6 +-
be/test/storage/tablet/tablet_index_test.cpp | 12 +-
be/test/storage/tablet/tablet_schema_helper.cpp | 4 +-
be/test/storage/tablet/tablet_schema_helper.h | 6 +-
be/test/storage/tablet/tablet_schema_test.cpp | 10 +-
be/test/testutil/column_helper.cpp | 4 +-
be/test/testutil/column_helper.h | 4 +-
be/test/testutil/creators.h | 24 +-
be/test/testutil/desc_tbl_builder.cpp | 17 +-
be/test/testutil/desc_tbl_builder.h | 10 +-
be/test/testutil/function_utils.cpp | 5 +-
be/test/testutil/function_utils.h | 4 +-
be/test/testutil/mock/mock_agg_fn_evaluator.cpp | 4 +-
be/test/testutil/mock/mock_agg_fn_evaluator.h | 4 +-
be/test/testutil/mock/mock_data_stream_sender.h | 7 +-
be/test/testutil/mock/mock_descriptors.h | 4 +-
be/test/testutil/mock/mock_fn_call.cpp | 4 +-
be/test/testutil/mock/mock_fn_call.h | 4 +-
be/test/testutil/mock/mock_in_expr.cpp | 8 +-
be/test/testutil/mock/mock_in_expr.h | 4 +-
be/test/testutil/mock/mock_literal_expr.cpp | 4 +-
be/test/testutil/mock/mock_literal_expr.h | 2 -
be/test/testutil/mock/mock_operators.h | 17 +-
be/test/testutil/mock/mock_slot_ref.cpp | 4 +-
be/test/testutil/mock/mock_slot_ref.h | 2 -
be/test/testutil/mock/mock_sorter.h | 4 +-
be/test/testutil/run_all_tests.cpp | 2 +-
be/test/testutil/test_util.cpp | 15 +-
be/test/testutil/test_util.h | 13 +-
be/test/testutil/variant_util.h | 132 ++---
be/test/udf/python/python_udf_meta_test.cpp | 22 +-
be/test/util/bit_util_test.cpp | 42 +-
be/test/util/char_type_padding_test.cpp | 4 +-
be/test/util/counts_test.cpp | 8 +-
be/test/util/decompress_test.cpp | 2 +-
be/test/util/jsonb_serialize_test.cpp | 9 +-
be/test/util/profile_spec_test.cpp | 6 +-
be/test/util/threadpool_test.cpp | 5 +
cloud/src/meta-store/keys.cpp | 9 -
cloud/src/meta-store/keys.h | 7 -
cloud/src/recycler/recycler.cpp | 124 ++--
cloud/src/recycler/recycler.h | 7 +-
.../cloud/alter/CloudSchemaChangeHandler.java | 6 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 23 +-
.../apache/doris/datasource/InternalCatalog.java | 4 +-
.../commands/info/ModifyTablePropertiesOp.java | 26 +-
.../insert_p0/insert_group_commit_into.groovy | 34 ++
2027 files changed, 14472 insertions(+), 17287 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
