This is an automated email from the ASF dual-hosted git repository.
kakachen pushed a change to branch data_lake_reader_refactoring
in repository https://gitbox.apache.org/repos/asf/doris.git
discard ae53802c33f fix build && type (#62352)
omit 4541ae1b562 fix v3 (#62305)
omit 489263cd454 update push down agg.
omit a486bb83080 update.
omit 0fc9862e387 update
omit 023626897b6 remove _fill_columns_from_path.
omit 787fde86daf fix
omit fde3a876c39 [refactor](be) Migrate parquet test files to new NVI
init_reader API
omit 85790ffef86 update.
omit f6e99d6b32a [fix](be) Fix standalone reader init for Parquet and ORC
omit dd072c05366 [refactor](be) Move fill-column computation to
on_before_init_reader
omit 9986fb26eba [refactor](be) Move column-filling logic from
GenericReader to TableFormatReader
omit bd9a12f7f96 [refactor](be) Introduce TableFormatReader with auto
column filling
omit 15417ab85b8 [refactor](be) Apply NVI template to get_next_block
omit 2db5544a82f [refactor](be) Unify all standalone readers to use NVI
init_reader
omit bb6cb3730b5 unify reader init.
omit e47dc56a8a0 fix.
omit 57d1d99b50c 1. Refactor count agg push down. 2. Load query decoupling.
3. unify FE default value.
omit 5d7d362ef88 [refactoring](multi-catalog)data_lake_reader_refactoring.
add 8c53f070fb5 Support ANN index on MoW table (#61994)
add 0f7a1c316da [opt](expr) Remove FixedContainer optimization for
StringValueSet (#62243)
add 791c56d85db [feature](inverted index) support DROP INDEX ON PARTITION
for inverted index (#62181)
add c2cc2998fed [chore](join node) remove useless innerRef field in
JoinNodeBase (#62292)
add 9fdcd552f5f [Chore](tool) enlarge tpch sf1000 supplier buckets number
(#62214)
add 11406e9d66e [refactor](Descriptor) remove TupleDescriptor's
TableRefInfo (#62290)
add e45d3cefda4 [refactor](desc) use TupleID in SlotDescriptor to avoid
import TupleDescriptor in it (#62280)
add 91d349c2fba [chore](expr) decouple Expr from unnecessary class (#62279)
add 4813be5ba31 [improvement](fe) Enhance COALESCE simplification to
remove all NullLiterals (#62266)
add c2f9c2fa0b4 [fix](ldap) Improve LDAP authentication resiliency and
diagnostics (#61673)
add dd59f479af5 [fix](cloud) Delete local rowsets before add_rowsets in
cloud schema change (#62256)
add d23d9ca4d03 [fix](be) Restore workload group limit refresh after
memory recovery (#62070)
add e2e5159b98e [feature](fe) Add information_schema role mappings table
(#62077)
add a8ef64bc748 [fix](fe-dep) upgrade vulnerable dependencies (#62274)
add 5d6478002e5 [config] Change default value of
max_bucket_num_per_partition to 768 (#62286)
add 7aa904c42ca [refine](function) split monolithic function_string.h into
domain-specific files (#62262)
add 61ab06990ec [fix](tvf) fix tvf return error since thrift message too
large to reach limit (#61788)
add 3d7594249fd [chore](build) Add code style enforcement documentation,
skills, and clang-tidy script (#62307)
add 6f21ae42659 [fix](cloud) Add predecessor instance id (#62276)
add a39563954eb [test](regression) Shorten generated HMS and DLF
identifiers in catalog case (#62313)
add 8e7da140120 [improvement](be) Remove redundant compile check wrappers
(#62300)
add 60f736eea7a [chore](docker) Make DORIS_CLOUD_PREFIX unique with
timestamp and UUID suffix (#62275)
add 2a812342ba6 [fix](fe) Return early for non-master stream load
precommit (#62109)
add 000395ded91 [fix](fe) Fix redundant aggregation in agg-union query
plan (#62231)
add b74f32faf2e [Fix](compile) fix missing headers (#62340)
add 795a4d06dcb [refactor](fe) Extract toThrift from descriptor classes
into DescriptorToThriftConverter (#62312)
add fcad2a12a82 [refactoring](multi-catalog)data_lake_reader_refactoring.
add 5420e854524 1. Refactor count agg push down. 2. Load query decoupling.
3. unify FE default value.
add 9f8c8ebf641 fix.
add 0c6293fe03d unify reader init.
add c7272c2dd90 [refactor](be) Unify all standalone readers to use NVI
init_reader
add e1b3a02b7ab [refactor](be) Apply NVI template to get_next_block
add bc381e55e6b [refactor](be) Introduce TableFormatReader with auto
column filling
add 09c4b71e0fb [refactor](be) Move column-filling logic from
GenericReader to TableFormatReader
add 08bccb373f5 [refactor](be) Move fill-column computation to
on_before_init_reader
add 00ff751a699 [fix](be) Fix standalone reader init for Parquet and ORC
add 9737aedfcf0 update.
add e4b7793d043 [refactor](be) Migrate parquet test files to new NVI
init_reader API
add 79fa1d86bdf fix
add 7afb6dcb1f7 remove _fill_columns_from_path.
add e0e1f6b21de update
add 4e4c5cfcc54 update.
add 55d18815e60 update push down agg.
add 5b2f94c6324 fix v3 (#62305)
add 3e44d1e5ad5 fix build && type (#62352)
add 29774b42a3b remove compile check
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 (ae53802c33f)
\
N -- N -- N refs/heads/data_lake_reader_refactoring (29774b42a3b)
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:
.claude/skills/be-code-style/SKILL.md | 67 +
.claude/skills/clang-tidy-check/SKILL.md | 138 +
.claude/skills/fe-code-style/SKILL.md | 102 +
AGENTS.md | 10 +
be/benchmark/benchmark_bit_pack.hpp | 12 +-
be/benchmark/benchmark_hybrid_set.hpp | 190 +
be/benchmark/benchmark_main.cpp | 1 +
be/benchmark/benchmark_string.hpp | 34 +-
be/benchmark/binary_cast_benchmark.hpp | 12 +-
be/src/agent/cgroup_cpu_ctl.cpp | 4 -
be/src/agent/task_worker_pool.cpp | 4 +-
be/src/agent/workload_group_listener.cpp | 3 -
be/src/cloud/cloud_committed_rs_mgr.cpp | 2 -
be/src/cloud/cloud_committed_rs_mgr.h | 2 -
be/src/cloud/cloud_cumulative_compaction.cpp | 2 -
be/src/cloud/cloud_cumulative_compaction.h | 2 -
.../cloud/cloud_cumulative_compaction_policy.cpp | 2 -
be/src/cloud/cloud_cumulative_compaction_policy.h | 2 -
.../cloud/cloud_engine_calc_delete_bitmap_task.cpp | 2 -
be/src/cloud/cloud_internal_service.cpp | 3 -
be/src/cloud/cloud_meta_mgr.cpp | 2 -
be/src/cloud/cloud_meta_mgr.h | 2 -
be/src/cloud/cloud_rowset_builder.cpp | 2 -
be/src/cloud/cloud_schema_change_job.cpp | 23 +
be/src/cloud/cloud_snapshot_loader.h | 2 -
be/src/cloud/cloud_snapshot_mgr.cpp | 2 -
be/src/cloud/cloud_storage_engine.cpp | 2 -
be/src/cloud/cloud_tablet.cpp | 31 +-
be/src/cloud/cloud_tablet.h | 7 +
be/src/cloud/cloud_tablets_channel.cpp | 2 -
be/src/cloud/cloud_warm_up_manager.cpp | 2 -
be/src/cloud/config.cpp | 2 -
be/src/cloud/config.h | 2 -
be/src/cloud/delete_bitmap_file_reader.cpp | 2 -
be/src/cloud/delete_bitmap_file_writer.cpp | 2 -
be/src/cloud/pb_convert.cpp | 2 -
be/src/common/AGENTS.md | 7 +-
be/src/common/be_mock_util.cpp | 2 -
be/src/common/compare.h | 3 -
be/src/common/compile_check_begin.h | 30 -
be/src/common/config.cpp | 2 +-
be/src/common/config.h | 2 +-
be/src/common/metrics/system_metrics.cpp | 1 -
be/src/core/block/block.cpp | 2 -
be/src/core/column/column_const.cpp | 1 -
be/src/core/column/column_const.h | 2 -
be/src/core/column/column_decimal.h | 2 -
be/src/core/column/column_dictionary.h | 2 -
be/src/core/column/column_nullable.cpp | 1 -
be/src/core/column/column_nullable.h | 2 -
be/src/core/column/column_string.cpp | 1 -
be/src/core/column/column_string.h | 2 -
be/src/core/column/column_varbinary.cpp | 2 -
be/src/core/column/column_varbinary.h | 2 -
be/src/core/column/column_variant.cpp | 4 -
be/src/core/column/column_vector.cpp | 1 -
be/src/core/column/column_vector.h | 2 -
be/src/core/column/predicate_column.h | 2 -
be/src/core/cow.h | 2 -
be/src/core/custom_allocator.h | 2 -
be/src/core/data_type/convert_field_to_type.cpp | 2 -
be/src/core/data_type/data_type.cpp | 1 -
be/src/core/data_type/data_type.h | 2 -
be/src/core/data_type/data_type_bitmap.cpp | 1 -
be/src/core/data_type/data_type_date.h | 2 -
.../data_type/data_type_date_or_datetime_v2.cpp | 1 -
.../core/data_type/data_type_date_or_datetime_v2.h | 2 -
be/src/core/data_type/data_type_date_time.h | 3 -
be/src/core/data_type/data_type_decimal.cpp | 1 -
be/src/core/data_type/data_type_decimal.h | 2 -
be/src/core/data_type/data_type_factory.cpp | 1 -
.../data_type/data_type_fixed_length_object.cpp | 1 -
be/src/core/data_type/data_type_ipv4.cpp | 4 -
be/src/core/data_type/data_type_jsonb.cpp | 1 -
be/src/core/data_type/data_type_jsonb.h | 2 -
be/src/core/data_type/data_type_nullable.cpp | 1 -
be/src/core/data_type/data_type_number_base.cpp | 1 -
be/src/core/data_type/data_type_number_base.h | 2 -
be/src/core/data_type/data_type_quantilestate.cpp | 1 -
be/src/core/data_type/data_type_string.cpp | 1 -
be/src/core/data_type/data_type_varbinary.cpp | 1 -
be/src/core/data_type/data_type_variant.cpp | 1 -
be/src/core/data_type/primitive_type.h | 2 -
.../core/data_type_serde/data_type_array_serde.cpp | 1 -
.../data_type_serde/data_type_bitmap_serde.cpp | 1 -
.../data_type_date_or_datetime_serde.cpp | 1 -
.../data_type_serde/data_type_datetimev2_serde.cpp | 1 -
.../data_type_serde/data_type_datev2_serde.cpp | 1 -
.../data_type_serde/data_type_decimal_serde.cpp | 1 -
.../core/data_type_serde/data_type_decimal_serde.h | 2 -
.../core/data_type_serde/data_type_hll_serde.cpp | 1 -
.../core/data_type_serde/data_type_ipv4_serde.cpp | 1 -
.../core/data_type_serde/data_type_ipv6_serde.cpp | 1 -
.../core/data_type_serde/data_type_jsonb_serde.cpp | 1 -
.../core/data_type_serde/data_type_map_serde.cpp | 1 -
be/src/core/data_type_serde/data_type_map_serde.h | 2 -
.../data_type_serde/data_type_nullable_serde.cpp | 1 -
.../data_type_serde/data_type_nullable_serde.h | 2 -
.../data_type_serde/data_type_number_serde.cpp | 1 -
.../core/data_type_serde/data_type_number_serde.h | 2 -
.../data_type_quantilestate_serde.h | 2 -
be/src/core/data_type_serde/data_type_serde.cpp | 1 -
be/src/core/data_type_serde/data_type_serde.h | 2 -
.../core/data_type_serde/data_type_string_serde.h | 2 -
.../data_type_serde/data_type_struct_serde.cpp | 1 -
.../core/data_type_serde/data_type_struct_serde.h | 2 -
.../core/data_type_serde/data_type_time_serde.cpp | 1 -
be/src/core/data_type_serde/data_type_time_serde.h | 2 -
.../data_type_serde/data_type_varbinary_serde.h | 2 -
.../data_type_serde/data_type_variant_serde.cpp | 2 -
.../core/data_type_serde/data_type_variant_serde.h | 2 -
be/src/core/decimal12.h | 2 -
be/src/core/memcmp_small.h | 3 -
be/src/core/string_ref.cpp | 2 -
be/src/core/string_ref.h | 2 -
be/src/core/string_view.h | 2 -
be/src/core/types.h | 2 -
be/src/core/value/decimalv2_value.cpp | 2 -
be/src/core/value/decimalv2_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 | 2 -
be/src/core/value/ipv4_value.h | 3 -
be/src/core/value/ipv6_value.h | 3 -
be/src/core/value/jsonb_value.h | 2 -
be/src/core/value/large_int_value.h | 2 -
be/src/core/value/quantile_state.cpp | 1 -
be/src/core/value/time_value.h | 4 +-
be/src/core/wide_integer_impl.h | 2 -
be/src/exec/common/endian.h | 2 -
be/src/exec/common/format_ip.h | 2 -
be/src/exec/common/hash_table/hash_map_context.h | 2 -
be/src/exec/common/hash_table/hash_table.h | 2 -
.../exec/common/hash_table/hash_table_set_build.h | 2 -
.../exec/common/hash_table/hash_table_set_probe.h | 2 -
be/src/exec/common/hash_table/join_hash_table.h | 2 -
be/src/exec/common/histogram_helpers.hpp | 2 -
be/src/exec/common/partition_sort_utils.cpp | 2 -
be/src/exec/common/sip_hash.h | 2 -
be/src/exec/common/string_searcher.h | 2 -
be/src/exec/common/stringop_substring.h | 3 -
be/src/exec/common/varbinaryop_subbinary.h | 2 -
be/src/exec/common/variant_util.cpp | 2 -
be/src/exec/es/es_scroll_parser.cpp | 2 -
be/src/exec/exchange/exchange_writer.cpp | 1 -
be/src/exec/exchange/exchange_writer.h | 2 -
be/src/exec/exchange/local_exchanger.cpp | 1 -
be/src/exec/exchange/local_exchanger.h | 2 -
be/src/exec/exchange/vdata_stream_mgr.cpp | 1 -
be/src/exec/exchange/vdata_stream_mgr.h | 3 -
be/src/exec/exchange/vdata_stream_recvr.cpp | 1 -
be/src/exec/exchange/vdata_stream_recvr.h | 3 -
be/src/exec/exchange/vdata_stream_sender.cpp | 1 -
be/src/exec/exchange/vdata_stream_sender.h | 3 -
be/src/exec/operator/aggregation_sink_operator.cpp | 1 -
be/src/exec/operator/aggregation_sink_operator.h | 2 -
.../exec/operator/aggregation_source_operator.cpp | 1 -
be/src/exec/operator/aggregation_source_operator.h | 2 -
be/src/exec/operator/analytic_sink_operator.cpp | 1 -
be/src/exec/operator/analytic_sink_operator.h | 2 -
be/src/exec/operator/analytic_source_operator.cpp | 1 -
be/src/exec/operator/analytic_source_operator.h | 3 -
be/src/exec/operator/assert_num_rows_operator.cpp | 1 -
be/src/exec/operator/assert_num_rows_operator.h | 2 -
be/src/exec/operator/cache_sink_operator.cpp | 1 -
be/src/exec/operator/cache_sink_operator.h | 2 -
be/src/exec/operator/cache_source_operator.cpp | 1 -
be/src/exec/operator/cache_source_operator.h | 2 -
be/src/exec/operator/data_queue.cpp | 1 -
be/src/exec/operator/data_queue.h | 2 -
be/src/exec/operator/datagen_operator.cpp | 1 -
be/src/exec/operator/datagen_operator.h | 2 -
be/src/exec/operator/dict_sink_operator.cpp | 2 -
be/src/exec/operator/dict_sink_operator.h | 2 -
.../distinct_streaming_aggregation_operator.cpp | 1 -
.../distinct_streaming_aggregation_operator.h | 2 -
be/src/exec/operator/empty_set_operator.cpp | 2 -
be/src/exec/operator/empty_set_operator.h | 2 -
be/src/exec/operator/es_scan_operator.cpp | 1 -
be/src/exec/operator/es_scan_operator.h | 2 -
be/src/exec/operator/exchange_sink_buffer.cpp | 2 -
be/src/exec/operator/exchange_sink_buffer.h | 2 -
be/src/exec/operator/exchange_sink_operator.cpp | 1 -
be/src/exec/operator/exchange_sink_operator.h | 2 -
be/src/exec/operator/exchange_source_operator.cpp | 1 -
be/src/exec/operator/exchange_source_operator.h | 2 -
be/src/exec/operator/file_scan_operator.cpp | 1 -
be/src/exec/operator/file_scan_operator.h | 2 -
.../operator/group_commit_block_sink_operator.cpp | 1 -
.../operator/group_commit_block_sink_operator.h | 2 -
.../exec/operator/group_commit_scan_operator.cpp | 1 -
be/src/exec/operator/group_commit_scan_operator.h | 2 -
be/src/exec/operator/hashjoin_build_sink.cpp | 1 -
be/src/exec/operator/hashjoin_build_sink.h | 2 -
be/src/exec/operator/hashjoin_probe_operator.cpp | 1 -
be/src/exec/operator/hashjoin_probe_operator.h | 2 -
be/src/exec/operator/hive_table_sink_operator.cpp | 1 -
be/src/exec/operator/hive_table_sink_operator.h | 2 -
.../exec/operator/iceberg_delete_sink_operator.cpp | 1 -
.../exec/operator/iceberg_delete_sink_operator.h | 2 -
.../exec/operator/iceberg_merge_sink_operator.cpp | 2 -
be/src/exec/operator/iceberg_merge_sink_operator.h | 2 -
.../exec/operator/iceberg_table_sink_operator.cpp | 1 -
be/src/exec/operator/iceberg_table_sink_operator.h | 2 -
be/src/exec/operator/jdbc_scan_operator.cpp | 1 -
be/src/exec/operator/jdbc_scan_operator.h | 2 -
be/src/exec/operator/jdbc_table_sink_operator.cpp | 1 -
be/src/exec/operator/jdbc_table_sink_operator.h | 2 -
.../operator/join/process_hash_table_probe_impl.h | 2 -
be/src/exec/operator/join_build_sink_operator.cpp | 1 -
be/src/exec/operator/join_build_sink_operator.h | 2 -
be/src/exec/operator/join_probe_operator.cpp | 1 -
be/src/exec/operator/join_probe_operator.h | 2 -
.../operator/local_merge_sort_source_operator.cpp | 2 -
.../operator/local_merge_sort_source_operator.h | 2 -
be/src/exec/operator/materialization_opertor.h | 2 -
.../operator/maxcompute_table_sink_operator.cpp | 1 -
.../exec/operator/maxcompute_table_sink_operator.h | 2 -
.../exec/operator/memory_scratch_sink_operator.cpp | 1 -
.../exec/operator/memory_scratch_sink_operator.h | 2 -
be/src/exec/operator/meta_scan_operator.cpp | 1 -
be/src/exec/operator/meta_scan_operator.h | 2 -
.../exec/operator/multi_cast_data_stream_sink.cpp | 1 -
be/src/exec/operator/multi_cast_data_stream_sink.h | 2 -
.../operator/multi_cast_data_stream_source.cpp | 1 -
.../exec/operator/multi_cast_data_stream_source.h | 2 -
be/src/exec/operator/multi_cast_data_streamer.cpp | 1 -
be/src/exec/operator/multi_cast_data_streamer.h | 2 -
.../operator/nested_loop_join_build_operator.cpp | 1 -
.../operator/nested_loop_join_build_operator.h | 2 -
.../operator/nested_loop_join_probe_operator.cpp | 1 -
.../operator/nested_loop_join_probe_operator.h | 2 -
be/src/exec/operator/olap_scan_operator.cpp | 2 -
be/src/exec/operator/olap_scan_operator.h | 2 -
be/src/exec/operator/olap_table_sink_operator.h | 2 -
be/src/exec/operator/olap_table_sink_v2_operator.h | 2 -
be/src/exec/operator/operator.cpp | 2 -
be/src/exec/operator/operator.h | 2 -
.../exec/operator/partition_sort_sink_operator.cpp | 2 -
.../exec/operator/partition_sort_sink_operator.h | 2 -
.../operator/partition_sort_source_operator.cpp | 2 -
.../exec/operator/partition_sort_source_operator.h | 2 -
.../partitioned_aggregation_sink_operator.cpp | 2 -
.../partitioned_aggregation_sink_operator.h | 2 -
.../partitioned_aggregation_source_operator.cpp | 3 -
.../partitioned_aggregation_source_operator.h | 2 -
.../partitioned_hash_join_probe_operator.cpp | 3 -
.../partitioned_hash_join_probe_operator.h | 2 -
.../partitioned_hash_join_sink_operator.cpp | 2 -
.../operator/partitioned_hash_join_sink_operator.h | 2 -
.../exec/operator/rec_cte_anchor_sink_operator.cpp | 1 -
.../exec/operator/rec_cte_anchor_sink_operator.h | 2 -
be/src/exec/operator/rec_cte_scan_operator.h | 2 -
be/src/exec/operator/rec_cte_sink_operator.cpp | 1 -
be/src/exec/operator/rec_cte_sink_operator.h | 2 -
be/src/exec/operator/rec_cte_source_operator.cpp | 1 -
be/src/exec/operator/rec_cte_source_operator.h | 2 -
be/src/exec/operator/repeat_operator.cpp | 2 -
be/src/exec/operator/repeat_operator.h | 2 -
be/src/exec/operator/result_file_sink_operator.cpp | 2 -
be/src/exec/operator/result_file_sink_operator.h | 2 -
be/src/exec/operator/result_sink_operator.cpp | 2 -
be/src/exec/operator/result_sink_operator.h | 2 -
be/src/exec/operator/scan_operator.cpp | 2 -
be/src/exec/operator/scan_operator.h | 2 -
be/src/exec/operator/schema_scan_operator.cpp | 2 -
be/src/exec/operator/schema_scan_operator.h | 2 -
be/src/exec/operator/select_operator.h | 2 -
be/src/exec/operator/set_probe_sink_operator.cpp | 2 -
be/src/exec/operator/set_probe_sink_operator.h | 2 -
be/src/exec/operator/set_sink_operator.cpp | 1 -
be/src/exec/operator/set_sink_operator.h | 2 -
be/src/exec/operator/set_source_operator.cpp | 1 -
be/src/exec/operator/set_source_operator.h | 2 -
be/src/exec/operator/sort_sink_operator.cpp | 2 -
be/src/exec/operator/sort_sink_operator.h | 2 -
be/src/exec/operator/sort_source_operator.cpp | 2 -
.../operator/spill_iceberg_table_sink_operator.cpp | 2 -
.../operator/spill_iceberg_table_sink_operator.h | 2 -
be/src/exec/operator/spill_sort_sink_operator.cpp | 2 -
be/src/exec/operator/spill_sort_sink_operator.h | 2 -
.../exec/operator/spill_sort_source_operator.cpp | 2 -
be/src/exec/operator/spill_sort_source_operator.h | 2 -
be/src/exec/operator/spill_utils.h | 3 -
.../operator/streaming_aggregation_operator.cpp | 2 -
.../exec/operator/streaming_aggregation_operator.h | 2 -
be/src/exec/operator/table_function_operator.cpp | 2 -
be/src/exec/operator/table_function_operator.h | 2 -
be/src/exec/operator/tvf_table_sink_operator.cpp | 1 -
be/src/exec/operator/tvf_table_sink_operator.h | 2 -
be/src/exec/operator/union_sink_operator.cpp | 2 -
be/src/exec/operator/union_sink_operator.h | 2 -
be/src/exec/operator/union_source_operator.cpp | 2 -
be/src/exec/operator/union_source_operator.h | 2 -
be/src/exec/partitioner/partitioner.cpp | 1 -
be/src/exec/partitioner/partitioner.h | 2 -
be/src/exec/pipeline/dependency.cpp | 1 -
be/src/exec/pipeline/dependency.h | 2 -
be/src/exec/pipeline/pipeline.h | 2 -
be/src/exec/pipeline/pipeline_fragment_context.cpp | 2 -
be/src/exec/pipeline/pipeline_task.cpp | 2 -
be/src/exec/pipeline/rec_cte_shared_state.h | 2 -
be/src/exec/pipeline/task_queue.cpp | 1 -
be/src/exec/pipeline/task_queue.h | 2 -
be/src/exec/pipeline/task_scheduler.cpp | 1 -
be/src/exec/rowid_fetcher.cpp | 4 -
be/src/exec/runtime_filter/runtime_filter.cpp | 1 -
be/src/exec/runtime_filter/runtime_filter.h | 2 -
.../runtime_filter/runtime_filter_consumer.cpp | 1 -
.../exec/runtime_filter/runtime_filter_consumer.h | 2 -
.../runtime_filter_consumer_helper.cpp | 1 -
.../runtime_filter_consumer_helper.h | 2 -
.../runtime_filter/runtime_filter_definitions.h | 2 -
be/src/exec/runtime_filter/runtime_filter_merger.h | 2 -
be/src/exec/runtime_filter/runtime_filter_mgr.cpp | 1 -
be/src/exec/runtime_filter/runtime_filter_mgr.h | 2 -
.../runtime_filter/runtime_filter_producer.cpp | 1 -
.../exec/runtime_filter/runtime_filter_producer.h | 2 -
.../runtime_filter_producer_helper.cpp | 1 -
.../runtime_filter_producer_helper.h | 2 -
.../runtime_filter_producer_helper_cross.h | 2 -
.../runtime_filter_producer_helper_set.h | 2 -
.../exec/runtime_filter/runtime_filter_wrapper.cpp | 1 -
.../exec/runtime_filter/runtime_filter_wrapper.h | 2 -
be/src/exec/runtime_filter/utils.cpp | 1 -
be/src/exec/runtime_filter/utils.h | 2 -
be/src/exec/scan/file_scanner.cpp | 1 -
be/src/exec/scan/meta_scanner.cpp | 2 -
be/src/exec/scan/meta_scanner.h | 2 -
be/src/exec/scan/scanner_context.cpp | 2 -
be/src/exec/scan/split_source_connector.h | 2 -
.../time_sharing/time_sharing_task_executor.cpp | 1 -
.../time_sharing/time_sharing_task_handle.cpp | 1 -
be/src/exec/scan/vector_search_user_params.cpp | 1 -
be/src/exec/scan/vector_search_user_params.h | 2 -
be/src/exec/sink/autoinc_buffer.cpp | 1 -
be/src/exec/sink/autoinc_buffer.h | 2 -
be/src/exec/sink/delta_writer_v2_pool.cpp | 1 -
be/src/exec/sink/delta_writer_v2_pool.h | 3 -
be/src/exec/sink/load_stream_map_pool.cpp | 1 -
be/src/exec/sink/load_stream_map_pool.h | 3 -
be/src/exec/sink/load_stream_stub.cpp | 1 -
be/src/exec/sink/load_stream_stub.h | 3 -
.../sink/scale_writer_partitioning_exchanger.hpp | 2 -
be/src/exec/sink/tablet_sink_hash_partitioner.cpp | 1 -
be/src/exec/sink/tablet_sink_hash_partitioner.h | 2 -
be/src/exec/sink/viceberg_merge_sink.cpp | 1 +
be/src/exec/sink/vrow_distribution.cpp | 1 -
be/src/exec/sink/vrow_distribution.h | 3 -
be/src/exec/sink/vtablet_block_convertor.cpp | 1 -
be/src/exec/sink/vtablet_block_convertor.h | 2 -
be/src/exec/sink/vtablet_finder.cpp | 1 -
be/src/exec/sink/vtablet_finder.h | 2 -
be/src/exec/sink/writer/async_result_writer.cpp | 2 -
be/src/exec/sink/writer/iceberg/partition_data.h | 2 -
.../sink/writer/iceberg/partition_transformers.h | 4 -
.../sink/writer/iceberg/viceberg_sort_writer.cpp | 2 -
.../sink/writer/iceberg/viceberg_table_writer.cpp | 1 -
.../sink/writer/maxcompute/vmc_table_writer.cpp | 1 -
.../sink/writer/varrow_flight_result_writer.cpp | 1 -
.../exec/sink/writer/varrow_flight_result_writer.h | 3 -
be/src/exec/sink/writer/vhive_table_writer.cpp | 1 -
be/src/exec/sink/writer/vmysql_result_writer.cpp | 1 -
be/src/exec/sink/writer/vmysql_result_writer.h | 3 -
be/src/exec/sink/writer/vtablet_writer.cpp | 2 -
be/src/exec/sink/writer/vtablet_writer_v2.cpp | 1 -
be/src/exec/sort/heap_sorter.cpp | 2 -
be/src/exec/sort/heap_sorter.h | 2 -
be/src/exec/sort/partition_sorter.h | 2 -
be/src/exec/sort/sort_block.cpp | 1 -
be/src/exec/sort/sort_block.h | 2 -
be/src/exec/sort/sort_cursor.h | 2 -
be/src/exec/sort/sorter.h | 2 -
be/src/exec/sort/topn_sorter.h | 2 -
be/src/exec/sort/vsorted_run_merger.cpp | 1 -
be/src/exec/sort/vsorted_run_merger.h | 3 -
be/src/exec/spill/spill_file.cpp | 1 -
be/src/exec/spill/spill_file.h | 2 -
be/src/exec/spill/spill_file_manager.cpp | 1 -
be/src/exec/spill/spill_file_manager.h | 2 -
be/src/exec/spill/spill_file_reader.cpp | 1 -
be/src/exec/spill/spill_file_reader.h | 2 -
be/src/exec/spill/spill_file_writer.cpp | 1 -
be/src/exec/spill/spill_file_writer.h | 3 -
be/src/exec/spill/spill_repartitioner.cpp | 2 -
be/src/exec/table_connector.cpp | 2 -
be/src/exprs/aggregate/aggregate_function.h | 3 -
be/src/exprs/aggregate/aggregate_function_ai_agg.h | 2 -
.../aggregate_function_approx_count_distinct.cpp | 1 -
.../aggregate_function_approx_count_distinct.h | 3 -
.../aggregate/aggregate_function_array_agg.cpp | 1 -
.../exprs/aggregate/aggregate_function_array_agg.h | 3 -
be/src/exprs/aggregate/aggregate_function_avg.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_avg.h | 3 -
.../aggregate/aggregate_function_avg_weighted.cpp | 1 -
.../aggregate/aggregate_function_avg_weighted.h | 3 -
be/src/exprs/aggregate/aggregate_function_binary.h | 3 -
be/src/exprs/aggregate/aggregate_function_bit.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_bit.h | 2 -
.../exprs/aggregate/aggregate_function_bitmap.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_bitmap.h | 2 -
.../aggregate/aggregate_function_bitmap_agg.cpp | 1 -
.../aggregate/aggregate_function_bitmap_agg.h | 2 -
.../aggregate/aggregate_function_bool_union.cpp | 2 -
.../aggregate/aggregate_function_bool_union.h | 3 -
.../exprs/aggregate/aggregate_function_collect.cpp | 1 -
.../exprs/aggregate/aggregate_function_collect.h | 3 -
.../aggregate/aggregate_function_collect_impl.h | 2 -
.../aggregate/aggregate_function_collect_limit.cpp | 1 -
.../aggregate_function_collect_no_limit.cpp | 1 -
.../aggregate/aggregate_function_combinator.h | 3 -
.../exprs/aggregate/aggregate_function_count.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_count.h | 3 -
.../aggregate/aggregate_function_count_by_enum.cpp | 1 -
.../aggregate/aggregate_function_count_by_enum.h | 2 -
.../exprs/aggregate/aggregate_function_covar.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_covar.h | 2 -
.../aggregate/aggregate_function_distinct.cpp | 1 -
.../exprs/aggregate/aggregate_function_distinct.h | 3 -
.../exprs/aggregate/aggregate_function_foreach.cpp | 1 -
.../exprs/aggregate/aggregate_function_foreach.h | 3 -
.../aggregate/aggregate_function_foreachv2.cpp | 1 -
.../aggregate_function_group_array_intersect.cpp | 1 -
.../aggregate_function_group_array_set_op.cpp | 1 -
.../aggregate_function_group_array_set_op.h | 3 -
.../aggregate_function_group_array_set_op_impl.h | 2 -
.../aggregate_function_group_array_union.cpp | 1 -
.../aggregate/aggregate_function_group_concat.cpp | 1 -
.../aggregate/aggregate_function_group_concat.h | 3 -
.../aggregate/aggregate_function_histogram.cpp | 1 -
.../exprs/aggregate/aggregate_function_histogram.h | 6 +-
.../aggregate/aggregate_function_hll_union_agg.cpp | 1 -
.../aggregate/aggregate_function_hll_union_agg.h | 3 -
.../exprs/aggregate/aggregate_function_java_udaf.h | 3 -
.../aggregate/aggregate_function_kurtosis.cpp | 1 -
.../aggregate_function_linear_histogram.cpp | 1 -
.../aggregate_function_linear_histogram.h | 3 -
be/src/exprs/aggregate/aggregate_function_map.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_map.h | 3 -
.../exprs/aggregate/aggregate_function_map_v2.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_map_v2.h | 3 -
.../exprs/aggregate/aggregate_function_min_max.cpp | 1 -
.../exprs/aggregate/aggregate_function_min_max.h | 3 -
.../aggregate/aggregate_function_min_max_by.cpp | 3 -
.../aggregate/aggregate_function_min_max_by.h | 3 -
.../aggregate/aggregate_function_min_max_impl.h | 2 -
be/src/exprs/aggregate/aggregate_function_null.h | 3 -
.../exprs/aggregate/aggregate_function_null_v2.h | 3 -
.../aggregate_function_orth_bitmap_expr_cal.cpp | 1 -
...gregate_function_orth_bitmap_expr_cal_count.cpp | 1 -
.../aggregate_function_orth_bitmap_intersect.cpp | 1 -
...regate_function_orth_bitmap_intersect_count.cpp | 1 -
.../aggregate_function_orth_bitmap_union_count.cpp | 1 -
.../aggregate_function_orth_intersect_count.cpp | 1 -
.../aggregate_function_orthogonal_bitmap.cpp | 1 -
.../aggregate_function_orthogonal_bitmap.h | 3 -
.../aggregate/aggregate_function_percentile.cpp | 2 -
.../aggregate/aggregate_function_percentile.h | 2 -
.../aggregate_function_percentile_reservoir.cpp | 2 -
.../exprs/aggregate/aggregate_function_product.h | 3 -
.../aggregate/aggregate_function_python_udaf.h | 3 -
.../aggregate_function_quantile_state.cpp | 1 -
.../aggregate/aggregate_function_quantile_state.h | 3 -
.../exprs/aggregate/aggregate_function_reader.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_reader.h | 3 -
.../aggregate_function_reader_first_last.h | 2 -
.../aggregate_function_reader_replace.cpp | 1 -
.../aggregate/aggregate_function_regr_union.cpp | 1 -
.../aggregate/aggregate_function_regr_union.h | 3 -
.../aggregate/aggregate_function_retention.cpp | 1 -
.../exprs/aggregate/aggregate_function_retention.h | 2 -
be/src/exprs/aggregate/aggregate_function_sem.cpp | 2 -
be/src/exprs/aggregate/aggregate_function_sem.h | 2 -
.../aggregate_function_sequence_match.cpp | 1 -
.../aggregate/aggregate_function_sequence_match.h | 3 -
.../aggregate_function_simple_factory.cpp | 1 -
.../aggregate/aggregate_function_simple_factory.h | 3 -
be/src/exprs/aggregate/aggregate_function_skew.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_sort.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_sort.h | 3 -
.../aggregate/aggregate_function_state_merge.h | 3 -
.../aggregate/aggregate_function_state_union.h | 3 -
.../exprs/aggregate/aggregate_function_statistic.h | 2 -
.../exprs/aggregate/aggregate_function_stddev.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_stddev.h | 3 -
be/src/exprs/aggregate/aggregate_function_sum.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_sum.h | 3 -
be/src/exprs/aggregate/aggregate_function_topn.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_topn.h | 6 +-
.../aggregate/aggregate_function_topn_array.cpp | 1 -
.../aggregate/aggregate_function_topn_weighted.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_uniq.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_uniq.h | 3 -
.../aggregate_function_uniq_distribute_key.cpp | 1 -
.../aggregate_function_uniq_distribute_key.h | 3 -
.../exprs/aggregate/aggregate_function_window.cpp | 1 -
be/src/exprs/aggregate/aggregate_function_window.h | 3 -
.../aggregate/aggregate_function_window_first.cpp | 2 -
.../aggregate/aggregate_function_window_funnel.cpp | 1 -
.../aggregate/aggregate_function_window_funnel.h | 3 -
.../aggregate_function_window_funnel_v2.cpp | 1 -
.../aggregate_function_window_funnel_v2.h | 3 -
.../aggregate/aggregate_function_window_impl.h | 2 -
.../aggregate/aggregate_function_window_lag.cpp | 2 -
.../aggregate/aggregate_function_window_last.cpp | 2 -
.../aggregate/aggregate_function_window_lead.cpp | 2 -
.../aggregate_function_window_nth_value.cpp | 2 -
be/src/exprs/aggregate/factory_helpers.h | 3 -
be/src/exprs/aggregate/helpers.h | 3 -
be/src/exprs/aggregate/moments.h | 2 -
be/src/exprs/block_bloom_filter.hpp | 2 -
be/src/exprs/block_bloom_filter_impl.cc | 2 -
be/src/exprs/bloom_filter_func.h | 2 -
be/src/exprs/bloom_filter_func_impl.h | 2 -
be/src/exprs/create_predicate_function.h | 27 +-
be/src/exprs/function/ai/ai_adapter.h | 2 -
be/src/exprs/function/ai/ai_functions.h | 2 -
.../function/array/function_array_contains_all.cpp | 2 -
.../exprs/function/array/function_array_element.h | 2 -
.../array/function_array_enumerate_uniq.cpp | 2 -
.../function/array/function_array_flatten.cpp | 1 -
.../function/array/function_array_intersect.cpp | 1 -
be/src/exprs/function/array/function_array_join.h | 2 -
be/src/exprs/function/array/function_array_map.h | 2 -
.../exprs/function/array/function_array_mapped.h | 2 -
be/src/exprs/function/array/function_array_nary.h | 2 -
.../exprs/function/array/function_array_range.cpp | 1 -
.../exprs/function/array/function_array_reverse.h | 1 +
.../function/array/function_array_shuffle.cpp | 1 -
.../exprs/function/array/function_array_sortby.cpp | 1 -
.../exprs/function/array/function_array_split.cpp | 1 -
.../exprs/function/array/function_array_union.cpp | 1 -
be/src/exprs/function/array/function_array_utils.h | 2 -
.../array/function_array_with_constant.cpp | 2 -
be/src/exprs/function/cast/cast_to_array.h | 2 -
.../function/cast/cast_to_basic_number_common.h | 2 -
be/src/exprs/function/cast/cast_to_date.h | 2 -
.../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 | 2 -
be/src/exprs/function/cast/cast_to_decimal.h | 2 -
be/src/exprs/function/cast/cast_to_float.h | 2 -
be/src/exprs/function/cast/cast_to_int.h | 2 -
be/src/exprs/function/cast/cast_to_ip.h | 2 -
be/src/exprs/function/cast/cast_to_jsonb.h | 2 -
be/src/exprs/function/cast/cast_to_map.h | 2 -
be/src/exprs/function/cast/cast_to_string.h | 2 -
be/src/exprs/function/cast/cast_to_struct.h | 2 -
be/src/exprs/function/cast/cast_to_time_impl.hpp | 4 +-
.../exprs/function/complex_hash_map_dictionary.cpp | 2 -
be/src/exprs/function/date_format_type.h | 2 -
be/src/exprs/function/date_time_transforms.h | 2 -
be/src/exprs/function/function.cpp | 2 -
be/src/exprs/function/function_bit_count.cpp | 1 -
be/src/exprs/function/function_bitmap.cpp | 1 -
be/src/exprs/function/function_collection_in.h | 3 -
be/src/exprs/function/function_compress.cpp | 2 -
be/src/exprs/function/function_conv.cpp | 1 -
be/src/exprs/function/function_convert_tz.cpp | 3 -
.../function/function_datetime_floor_ceil.cpp | 1 -
.../function/function_datetime_string_to_string.h | 3 -
be/src/exprs/function/function_encryption.cpp | 1 -
be/src/exprs/function/function_hash.cpp | 1 -
be/src/exprs/function/function_helpers.cpp | 2 -
be/src/exprs/function/function_hex.cpp | 1 -
be/src/exprs/function/function_hll.cpp | 1 -
be/src/exprs/function/function_ip.h | 3 -
be/src/exprs/function/function_json.cpp | 1 -
be/src/exprs/function/function_jsonb.cpp | 1 -
.../exprs/function/function_needs_to_handle_null.h | 2 -
be/src/exprs/function/function_regexp.cpp | 1 -
be/src/exprs/function/function_reverse.h | 2 +-
be/src/exprs/function/function_rpc.cpp | 1 -
be/src/exprs/function/function_score.cpp | 2 -
be/src/exprs/function/function_soundex.cpp | 2 -
be/src/exprs/function/function_split_by_regexp.cpp | 2 -
be/src/exprs/function/function_string.cpp | 66 +-
be/src/exprs/function/function_string.h | 5392 --------------------
be/src/exprs/function/function_string_basic.cpp | 393 ++
be/src/exprs/function/function_string_concat.h | 813 +++
be/src/exprs/function/function_string_digest.cpp | 253 +
be/src/exprs/function/function_string_format.h | 776 +++
be/src/exprs/function/function_string_mask.cpp | 243 +
be/src/exprs/function/function_string_misc.cpp | 1665 ++++++
be/src/exprs/function/function_string_replace.h | 507 ++
be/src/exprs/function/function_string_search.cpp | 881 ++++
be/src/exprs/function/function_string_url.cpp | 285 ++
.../function/function_time_value_to_field.cpp | 2 -
be/src/exprs/function/function_to_json.cpp | 1 -
be/src/exprs/function/function_tokenize.cpp | 2 -
be/src/exprs/function/function_varbinary.cpp | 2 -
be/src/exprs/function/function_varbinary.h | 2 -
be/src/exprs/function/functions_comparison.h | 2 -
.../function/functions_multi_string_position.cpp | 2 -
be/src/exprs/function/like.cpp | 2 -
be/src/exprs/function/match.cpp | 2 -
be/src/exprs/function/minus.cpp | 2 -
be/src/exprs/function/multiply.cpp | 2 -
be/src/exprs/function/plus.cpp | 2 -
be/src/exprs/function/random.cpp | 2 -
be/src/exprs/function/uniform.cpp | 2 -
be/src/exprs/function/url/functions_url.h | 2 -
be/src/exprs/function_context.cpp | 2 -
be/src/exprs/hybrid_set.h | 2 -
.../lambda_function/varray_filter_function.cpp | 2 -
.../exprs/lambda_function/varray_map_function.cpp | 2 -
.../exprs/lambda_function/varray_sort_function.cpp | 2 -
be/src/exprs/score_runtime.h | 2 -
.../exprs/table_function/python_udtf_function.cpp | 2 -
be/src/exprs/table_function/python_udtf_function.h | 2 -
be/src/exprs/table_function/table_function.h | 2 -
.../table_function/table_function_factory.cpp | 2 -
.../exprs/table_function/table_function_factory.h | 2 -
be/src/exprs/table_function/udf_table_function.cpp | 2 -
be/src/exprs/table_function/udf_table_function.h | 2 -
be/src/exprs/table_function/vexplode.cpp | 2 -
be/src/exprs/table_function/vexplode.h | 2 -
be/src/exprs/table_function/vexplode_bitmap.cpp | 2 -
be/src/exprs/table_function/vexplode_bitmap.h | 2 -
.../exprs/table_function/vexplode_json_object.cpp | 2 -
be/src/exprs/table_function/vexplode_json_object.h | 2 -
be/src/exprs/table_function/vexplode_map.cpp | 2 -
be/src/exprs/table_function/vexplode_map.h | 2 -
be/src/exprs/table_function/vexplode_numbers.cpp | 2 -
be/src/exprs/table_function/vexplode_numbers.h | 2 -
be/src/exprs/table_function/vexplode_v2.cpp | 3 -
be/src/exprs/table_function/vexplode_v2.h | 2 -
be/src/exprs/table_function/vjson_each.cpp | 2 -
be/src/exprs/table_function/vjson_each.h | 2 -
be/src/exprs/vbitmap_predicate.cpp | 2 -
be/src/exprs/vbloom_predicate.cpp | 2 -
be/src/exprs/vcase_expr.cpp | 2 -
be/src/exprs/vcast_expr.cpp | 2 -
be/src/exprs/vcompound_pred.h | 2 -
be/src/exprs/vdirect_in_predicate.h | 2 -
be/src/exprs/vectorized_agg_fn.cpp | 2 -
be/src/exprs/vectorized_agg_fn.h | 2 -
be/src/exprs/vectorized_fn_call.cpp | 2 -
be/src/exprs/vectorized_fn_call.h | 2 -
be/src/exprs/vexpr.cpp | 2 -
be/src/exprs/vexpr.h | 2 -
be/src/exprs/vexpr_context.cpp | 2 -
be/src/exprs/vin_predicate.cpp | 2 -
be/src/exprs/vinfo_func.cpp | 2 -
be/src/exprs/virtual_slot_ref.cpp | 2 -
be/src/exprs/virtual_slot_ref.h | 2 -
be/src/exprs/vliteral.cpp | 2 -
be/src/exprs/vmatch_predicate.cpp | 2 -
be/src/exprs/vruntimefilter_wrapper.cpp | 2 -
be/src/exprs/vruntimefilter_wrapper.h | 2 -
be/src/exprs/vtopn_pred.h | 2 -
be/src/format/arrow/arrow_block_convertor.cpp | 2 -
be/src/format/arrow/arrow_pip_input_stream.cpp | 2 -
be/src/format/arrow/arrow_pip_input_stream.h | 2 -
be/src/format/arrow/arrow_stream_reader.cpp | 2 -
be/src/format/arrow/arrow_stream_reader.h | 3 -
be/src/format/column_type_convert.cpp | 2 -
be/src/format/column_type_convert.h | 2 -
be/src/format/count_reader.h | 2 -
be/src/format/csv/csv_reader.cpp | 2 -
be/src/format/csv/csv_reader.h | 2 -
.../file_reader/new_plain_binary_line_reader.cpp | 2 -
.../file_reader/new_plain_binary_line_reader.h | 2 -
.../file_reader/new_plain_text_line_reader.cpp | 2 -
.../file_reader/new_plain_text_line_reader.h | 2 -
be/src/format/format_common.h | 2 -
be/src/format/generic_reader.h | 2 -
be/src/format/jni/jni_data_bridge.cpp | 2 -
be/src/format/jni/jni_data_bridge.h | 2 -
be/src/format/jni/jni_reader.cpp | 2 -
be/src/format/jni/jni_reader.h | 2 -
be/src/format/json/new_json_reader.cpp | 2 -
be/src/format/json/new_json_reader.h | 2 -
be/src/format/native/native_reader.cpp | 4 -
be/src/format/native/native_reader.h | 3 -
be/src/format/orc/orc_memory_pool.h | 2 -
be/src/format/orc/vorc_reader.cpp | 2 -
be/src/format/orc/vorc_reader.h | 2 -
be/src/format/parquet/arrow_memory_pool.cpp | 2 -
be/src/format/parquet/arrow_memory_pool.h | 2 -
be/src/format/parquet/bool_plain_decoder.cpp | 2 -
be/src/format/parquet/bool_plain_decoder.h | 2 -
be/src/format/parquet/bool_rle_decoder.cpp | 2 -
be/src/format/parquet/bool_rle_decoder.h | 2 -
be/src/format/parquet/byte_array_dict_decoder.cpp | 2 -
be/src/format/parquet/byte_array_dict_decoder.h | 2 -
be/src/format/parquet/byte_array_plain_decoder.cpp | 2 -
be/src/format/parquet/byte_array_plain_decoder.h | 2 -
.../format/parquet/byte_stream_split_decoder.cpp | 2 -
be/src/format/parquet/byte_stream_split_decoder.h | 2 -
be/src/format/parquet/decoder.cpp | 2 -
be/src/format/parquet/decoder.h | 2 -
be/src/format/parquet/delta_bit_pack_decoder.cpp | 2 -
be/src/format/parquet/delta_bit_pack_decoder.h | 3 -
be/src/format/parquet/fix_length_dict_decoder.hpp | 2 -
be/src/format/parquet/fix_length_plain_decoder.cpp | 4 -
be/src/format/parquet/fix_length_plain_decoder.h | 3 -
be/src/format/parquet/level_decoder.cpp | 2 -
be/src/format/parquet/level_decoder.h | 2 -
be/src/format/parquet/parquet_column_convert.cpp | 2 -
be/src/format/parquet/parquet_column_convert.h | 2 -
be/src/format/parquet/parquet_common.cpp | 2 -
be/src/format/parquet/parquet_common.h | 2 -
be/src/format/parquet/parquet_predicate.h | 2 -
be/src/format/parquet/parquet_thrift_util.h | 2 -
be/src/format/parquet/schema_desc.cpp | 3 -
be/src/format/parquet/schema_desc.h | 2 -
.../parquet/vparquet_column_chunk_reader.cpp | 2 -
.../format/parquet/vparquet_column_chunk_reader.h | 2 -
be/src/format/parquet/vparquet_column_reader.cpp | 3 -
be/src/format/parquet/vparquet_column_reader.h | 3 -
be/src/format/parquet/vparquet_file_metadata.cpp | 2 -
be/src/format/parquet/vparquet_file_metadata.h | 2 -
be/src/format/parquet/vparquet_group_reader.cpp | 2 -
be/src/format/parquet/vparquet_group_reader.h | 2 -
be/src/format/parquet/vparquet_page_index.cpp | 2 -
be/src/format/parquet/vparquet_page_index.h | 2 -
be/src/format/parquet/vparquet_page_reader.cpp | 2 -
be/src/format/parquet/vparquet_page_reader.h | 2 -
be/src/format/parquet/vparquet_reader.cpp | 2 -
be/src/format/parquet/vparquet_reader.h | 2 -
be/src/format/table/equality_delete.cpp | 2 -
be/src/format/table/equality_delete.h | 2 -
.../table/hive/hive_orc_nested_column_utils.cpp | 1 -
.../table/hive/hive_orc_nested_column_utils.h | 2 -
.../hive/hive_parquet_nested_column_utils.cpp | 1 -
.../table/hive/hive_parquet_nested_column_utils.h | 2 -
be/src/format/table/hive_reader.cpp | 2 -
be/src/format/table/hive_reader.h | 2 -
be/src/format/table/hudi_jni_reader.cpp | 2 -
be/src/format/table/hudi_jni_reader.h | 2 -
be/src/format/table/hudi_reader.cpp | 2 -
be/src/format/table/hudi_reader.h | 2 -
be/src/format/table/iceberg/arrow_schema_util.cpp | 2 -
be/src/format/table/iceberg/arrow_schema_util.h | 2 -
.../iceberg/iceberg_orc_nested_column_utils.cpp | 1 -
.../iceberg/iceberg_orc_nested_column_utils.h | 2 -
.../iceberg_parquet_nested_column_utils.cpp | 1 -
.../iceberg/iceberg_parquet_nested_column_utils.h | 2 -
be/src/format/table/iceberg/partition_spec.cpp | 2 -
be/src/format/table/iceberg/partition_spec.h | 2 -
.../format/table/iceberg/partition_spec_parser.cpp | 2 -
.../format/table/iceberg/partition_spec_parser.h | 2 -
be/src/format/table/iceberg/schema.cpp | 2 -
be/src/format/table/iceberg/schema.h | 2 -
be/src/format/table/iceberg/schema_parser.cpp | 2 -
be/src/format/table/iceberg/schema_parser.h | 2 -
be/src/format/table/iceberg/struct_like.h | 2 -
be/src/format/table/iceberg/types.cpp | 2 -
be/src/format/table/iceberg/types.h | 2 -
.../table/iceberg/unbound_partition_spec.cpp | 2 -
.../format/table/iceberg/unbound_partition_spec.h | 2 -
be/src/format/table/iceberg_reader.cpp | 2 -
be/src/format/table/iceberg_reader.h | 2 -
be/src/format/table/iceberg_reader_mixin.h | 2 -
.../format/table/iceberg_sys_table_jni_reader.cpp | 2 -
be/src/format/table/iceberg_sys_table_jni_reader.h | 2 -
be/src/format/table/jdbc_jni_reader.cpp | 2 -
be/src/format/table/jdbc_jni_reader.h | 3 -
be/src/format/table/max_compute_jni_reader.cpp | 2 -
be/src/format/table/max_compute_jni_reader.h | 2 -
be/src/format/table/nested_column_access_helper.h | 2 -
be/src/format/table/paimon_cpp_reader.cpp | 2 -
be/src/format/table/paimon_cpp_reader.h | 2 -
be/src/format/table/paimon_jni_reader.cpp | 2 -
be/src/format/table/paimon_jni_reader.h | 2 -
be/src/format/table/paimon_predicate_converter.cpp | 2 -
be/src/format/table/paimon_predicate_converter.h | 2 -
be/src/format/table/paimon_reader.cpp | 2 -
be/src/format/table/paimon_reader.h | 2 -
be/src/format/table/remote_doris_reader.cpp | 2 -
be/src/format/table/remote_doris_reader.h | 2 -
be/src/format/table/table_format_reader.h | 2 -
be/src/format/table/table_schema_change_helper.cpp | 2 -
be/src/format/table/table_schema_change_helper.h | 2 -
be/src/format/table/transactional_hive_common.cpp | 2 -
be/src/format/table/transactional_hive_common.h | 2 -
be/src/format/table/transactional_hive_reader.cpp | 2 -
be/src/format/table/transactional_hive_reader.h | 2 -
be/src/format/table/trino_connector_jni_reader.cpp | 2 -
be/src/format/table/trino_connector_jni_reader.h | 2 -
be/src/format/text/text_reader.cpp | 2 -
be/src/format/text/text_reader.h | 2 -
.../transformer/iceberg_partition_function.cpp | 2 -
.../transformer/iceberg_partition_function.h | 2 -
be/src/format/transformer/merge_partitioner.cpp | 2 -
be/src/format/transformer/merge_partitioner.h | 2 -
be/src/format/transformer/vcsv_transformer.cpp | 1 -
be/src/format/transformer/vcsv_transformer.h | 3 -
.../format/transformer/vfile_format_transformer.h | 3 -
.../format/transformer/vjni_format_transformer.h | 3 -
be/src/format/transformer/vnative_transformer.cpp | 4 -
be/src/format/transformer/vnative_transformer.h | 3 -
be/src/format/transformer/vorc_transformer.cpp | 1 -
be/src/format/transformer/vorc_transformer.h | 3 -
be/src/format/transformer/vparquet_transformer.cpp | 1 -
be/src/format/transformer/vparquet_transformer.h | 3 -
be/src/format/transformer/writer_assigner.h | 2 -
.../schema_active_queries_scanner.cpp | 1 -
.../schema_authentication_integrations_scanner.cpp | 2 -
.../schema_backend_active_tasks.cpp | 1 -
.../schema_backend_kerberos_ticket_cache.cpp | 1 -
.../schema_catalog_meta_cache_stats_scanner.cpp | 1 -
.../schema_cluster_snapshot_properties_scanner.cpp | 2 -
.../schema_cluster_snapshots_scanner.cpp | 2 -
.../schema_column_data_sizes_scanner.cpp | 2 -
.../information_schema/schema_columns_scanner.cpp | 1 -
.../schema_compaction_tasks_scanner.cpp | 2 -
.../schema_encryption_keys_scanner.cpp | 2 -
.../schema_file_cache_info_scanner.cpp | 1 -
.../schema_file_cache_statistics.cpp | 1 -
.../schema_partitions_scanner.cpp | 1 -
.../schema_processlist_scanner.cpp | 1 -
...canner.cpp => schema_role_mappings_scanner.cpp} | 47 +-
.../schema_role_mappings_scanner.h} | 41 +-
.../information_schema/schema_rowsets_scanner.cpp | 2 -
be/src/information_schema/schema_scanner.cpp | 3 +
.../schema_table_options_scanner.cpp | 1 -
.../schema_table_properties_scanner.cpp | 1 -
.../information_schema/schema_tablets_scanner.cpp | 2 -
.../schema_workload_group_privileges.cpp | 1 -
...chema_workload_group_resource_usage_scanner.cpp | 1 -
.../schema_workload_groups_scanner.cpp | 1 -
.../schema_workload_sched_policy_scanner.cpp | 1 -
be/src/io/cache/block_file_cache.cpp | 3 -
be/src/io/file_factory.cpp | 2 -
be/src/io/fs/buffered_reader.cpp | 4 -
be/src/io/fs/buffered_reader.h | 4 -
.../io/fs/connectivity/s3_connectivity_tester.cpp | 2 -
.../connectivity/storage_connectivity_tester.cpp | 2 -
be/src/io/fs/file_handle_cache.cpp | 4 -
be/src/io/fs/hdfs_file_reader.cpp | 2 -
be/src/io/fs/hdfs_file_writer.cpp | 2 -
be/src/io/fs/local_file_writer.cpp | 2 -
be/src/io/fs/s3_file_writer.cpp | 2 -
be/src/load/channel/load_stream.cpp | 2 -
be/src/load/channel/load_stream_writer.cpp | 2 -
be/src/load/delta_writer/delta_writer.cpp | 2 -
be/src/load/delta_writer/delta_writer_v2.cpp | 2 -
be/src/load/delta_writer/push_handler.cpp | 2 -
be/src/load/group_commit/group_commit_mgr.cpp | 2 -
be/src/load/group_commit/wal/wal_info.cpp | 2 -
be/src/load/group_commit/wal/wal_reader.cpp | 2 -
be/src/load/group_commit/wal/wal_reader.h | 2 -
be/src/load/load_path_mgr.cpp | 4 -
be/src/load/memtable/memtable.cpp | 2 -
be/src/load/routine_load/data_consumer_group.cpp | 2 -
be/src/load/routine_load/data_consumer_group.h | 2 -
be/src/load/stream_load/stream_load_context.cpp | 2 -
be/src/runtime/descriptors.cpp | 2 -
be/src/runtime/descriptors.h | 2 -
be/src/runtime/exec_env_init.cpp | 1 -
be/src/runtime/fragment_mgr.cpp | 3 -
be/src/runtime/fragment_mgr.h | 2 -
be/src/runtime/memory/cache_manager.cpp | 2 -
be/src/runtime/memory/cache_manager.h | 2 -
be/src/runtime/memory/cache_policy.cpp | 2 -
be/src/runtime/memory/cache_policy.h | 2 -
be/src/runtime/memory/global_memory_arbitrator.cpp | 2 -
be/src/runtime/memory/global_memory_arbitrator.h | 2 -
be/src/runtime/memory/heap_profiler.cpp | 2 -
be/src/runtime/memory/heap_profiler.h | 2 -
be/src/runtime/memory/jemalloc_control.cpp | 2 -
be/src/runtime/memory/jemalloc_control.h | 2 -
be/src/runtime/memory/lru_cache_policy.h | 2 -
be/src/runtime/memory/lru_cache_value_base.h | 2 -
be/src/runtime/memory/mem_counter.h | 2 -
be/src/runtime/memory/mem_tracker.h | 2 -
be/src/runtime/memory/mem_tracker_limiter.cpp | 2 -
be/src/runtime/memory/mem_tracker_limiter.h | 2 -
be/src/runtime/memory/memory_profile.cpp | 2 -
be/src/runtime/memory/memory_profile.h | 2 -
be/src/runtime/memory/memory_reclamation.cpp | 2 -
be/src/runtime/memory/memory_reclamation.h | 2 -
be/src/runtime/memory/thread_mem_tracker_mgr.cpp | 2 -
be/src/runtime/memory/thread_mem_tracker_mgr.h | 2 -
be/src/runtime/result_block_buffer.cpp | 2 -
be/src/runtime/runtime_profile.cpp | 1 -
be/src/runtime/runtime_profile.h | 2 -
be/src/runtime/runtime_state.cpp | 2 -
be/src/runtime/snapshot_loader.cpp | 2 -
be/src/runtime/workload_group/workload_group.cpp | 4 -
.../workload_group/workload_group_manager.cpp | 107 +-
.../workload_group/workload_group_metrics.cpp | 2 -
be/src/runtime/workload_management/cpu_context.cpp | 2 -
be/src/runtime/workload_management/cpu_context.h | 2 -
be/src/runtime/workload_management/io_context.h | 2 -
.../runtime/workload_management/memory_context.cpp | 2 -
.../runtime/workload_management/memory_context.h | 2 -
.../workload_management/query_task_controller.cpp | 2 -
.../workload_management/query_task_controller.h | 2 -
.../workload_management/resource_context.cpp | 2 -
.../runtime/workload_management/resource_context.h | 2 -
.../workload_management/task_controller.cpp | 2 -
.../runtime/workload_management/task_controller.h | 2 -
be/src/service/backend_service.cpp | 2 -
.../http/action/check_rpc_channel_action.cpp | 2 -
be/src/service/http/action/checksum_action.cpp | 2 -
.../http/action/compaction_profile_action.cpp | 4 -
.../http/action/compaction_score_action.cpp | 2 -
be/src/service/http/action/config_action.cpp | 2 -
.../service/http/action/delete_bitmap_action.cpp | 2 -
be/src/service/http/action/delete_bitmap_action.h | 2 -
.../service/http/action/reload_tablet_action.cpp | 2 -
.../http/action/reset_rpc_channel_action.cpp | 2 -
be/src/service/http/action/show_hotspot_action.cpp | 4 -
be/src/service/http/action/snapshot_action.cpp | 2 -
.../http/action/stream_load_forward_handler.cpp | 2 -
.../http/action/tablet_migration_action.cpp | 2 -
be/src/service/http/http_client.cpp | 2 -
be/src/service/http_service.cpp | 2 -
be/src/service/point_query_executor.cpp | 4 -
be/src/storage/compaction/base_compaction.cpp | 1 -
.../storage/compaction/collection_similarity.cpp | 2 -
be/src/storage/compaction/collection_similarity.h | 2 -
.../storage/compaction/collection_statistics.cpp | 2 -
be/src/storage/compaction/collection_statistics.h | 2 -
be/src/storage/compaction/compaction.cpp | 2 -
.../storage/compaction/cumulative_compaction.cpp | 2 -
.../compaction/cumulative_compaction_policy.cpp | 2 -
.../cumulative_compaction_time_series_policy.cpp | 2 -
be/src/storage/data_dir.cpp | 2 -
be/src/storage/delete/delete_bitmap_calculator.cpp | 2 -
be/src/storage/field.h | 2 -
be/src/storage/index/ann/ann_index.h | 2 -
be/src/storage/index/ann/ann_index_iterator.cpp | 2 -
be/src/storage/index/ann/ann_index_iterator.h | 2 -
be/src/storage/index/ann/ann_index_reader.cpp | 1 -
be/src/storage/index/ann/ann_index_reader.h | 2 -
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 | 1 -
.../storage/index/ann/ann_range_search_runtime.h | 2 -
be/src/storage/index/ann/ann_search_params.h | 2 -
be/src/storage/index/ann/ann_topn_runtime.cpp | 1 -
be/src/storage/index/ann/ann_topn_runtime.h | 2 -
be/src/storage/index/ann/faiss_ann_index.cpp | 1 -
be/src/storage/index/ann/faiss_ann_index.h | 2 -
be/src/storage/index/bloom_filter/bloom_filter.h | 2 -
.../bloom_filter/bloom_filter_index_reader.cpp | 2 -
.../bloom_filter/bloom_filter_index_writer.cpp | 2 -
.../index/bloom_filter/ngram_bloom_filter.cpp | 2 -
.../index/bloom_filter/ngram_bloom_filter.h | 2 -
be/src/storage/index/index_page.cpp | 2 -
be/src/storage/index/index_page.h | 2 -
be/src/storage/index/index_query_context.h | 2 -
be/src/storage/index/index_reader_helper.h | 2 -
be/src/storage/index/index_storage_format.cpp | 2 -
be/src/storage/index/index_storage_format_v1.cpp | 2 -
be/src/storage/index/index_storage_format_v2.cpp | 2 -
be/src/storage/index/index_writer.cpp | 2 -
be/src/storage/index/index_writer.h | 2 -
be/src/storage/index/indexed_column_writer.cpp | 2 -
.../storage/index/inverted/analyzer/analyzer.cpp | 2 -
.../index/inverted/analyzer/ik/IKTokenizer.cpp | 2 -
.../inverted/analyzer/ik/core/AnalyzeContext.cpp | 2 -
.../inverted/analyzer/ik/core/CJKSegmenter.cpp | 2 -
.../analyzer/ik/core/CN_QuantifierSegmenter.cpp | 2 -
.../inverted/analyzer/ik/core/CharacterUtil.h | 2 -
.../inverted/analyzer/ik/core/IKSegmenter.cpp | 2 -
.../inverted/analyzer/ik/core/LetterSegmenter.cpp | 2 -
.../char_filter/char_replace_char_filter.cpp | 2 -
.../inverted/inverted_index_compound_reader.cpp | 2 -
.../index/inverted/inverted_index_reader.cpp | 2 -
.../index/inverted/query/conjunction_query.cpp | 2 -
.../index/inverted/query/phrase_prefix_query.cpp | 2 -
.../inverted/query/phrase_query/phrase_matcher.h | 2 -
.../query/phrase_query/sloppy_phrase_matcher.cpp | 2 -
.../storage/index/inverted/query/query_helper.cpp | 2 -
be/src/storage/index/inverted/query/query_helper.h | 2 -
.../storage/index/inverted/query/regexp_query.cpp | 2 -
be/src/storage/index/inverted/query/term_query.cpp | 2 -
be/src/storage/index/inverted/query/term_query.h | 2 -
.../index/inverted/similarity/bm25_similarity.cpp | 2 -
.../index/inverted/similarity/bm25_similarity.h | 2 -
.../storage/index/inverted/similarity/similarity.h | 2 -
.../inverted/token_filter/ascii_folding_filter.cpp | 2 -
.../token_filter/word_delimiter_filter.cpp | 2 -
.../token_filter/word_delimiter_filter_factory.h | 2 -
be/src/storage/index/inverted/token_stream.h | 2 -
.../inverted/tokenizer/basic/basic_tokenizer.cpp | 2 -
.../char/char_group_tokenizer_factory.cpp | 2 -
.../tokenizer/char/char_group_tokenizer_factory.h | 2 -
.../inverted/tokenizer/char/char_tokenizer.cpp | 2 -
.../index/inverted/tokenizer/char/char_tokenizer.h | 2 -
.../index/inverted/tokenizer/icu/icu_tokenizer.cpp | 2 -
.../inverted/tokenizer/keyword/keyword_tokenizer.h | 2 -
.../inverted/tokenizer/ngram/ngram_tokenizer.cpp | 2 -
.../inverted/tokenizer/ngram/ngram_tokenizer.h | 2 -
.../tokenizer/standard/standard_tokenizer_impl.h | 2 -
.../index/inverted/util/docid_set_iterator.h | 2 -
be/src/storage/index/inverted/util/fixed_bit_set.h | 2 -
be/src/storage/index/inverted/util/mock_iterator.h | 2 -
.../storage/index/inverted/util/priority_queue.h | 2 -
be/src/storage/index/inverted/util/string_helper.h | 2 -
.../index/inverted/util/union_term_iterator.h | 2 -
be/src/storage/index/ordinal_page_index.cpp | 2 -
be/src/storage/index/primary_key_index.h | 2 -
be/src/storage/index/short_key_index.cpp | 2 -
be/src/storage/index/zone_map/zone_map_index.cpp | 2 -
be/src/storage/index/zone_map/zone_map_index.h | 2 -
be/src/storage/iterator/block_reader.cpp | 2 -
be/src/storage/iterator/olap_data_convertor.h | 4 -
be/src/storage/iterator/vcollect_iterator.cpp | 3 -
be/src/storage/iterator/vertical_block_reader.cpp | 2 -
.../storage/iterator/vertical_merge_iterator.cpp | 2 -
be/src/storage/iterator/vertical_merge_iterator.h | 2 -
be/src/storage/iterator/vgeneric_iterators.cpp | 4 -
be/src/storage/iterator/vgeneric_iterators.h | 4 -
be/src/storage/itoken_extractor.h | 2 -
be/src/storage/merger.cpp | 2 -
be/src/storage/olap_common.h | 2 -
be/src/storage/olap_scan_common.h | 2 -
be/src/storage/olap_server.cpp | 2 -
be/src/storage/partial_update_info.cpp | 1 -
be/src/storage/predicate/comparison_predicate.h | 2 -
be/src/storage/predicate/in_list_predicate.h | 2 -
be/src/storage/predicate/predicate_creator.h | 2 -
be/src/storage/row_cursor.cpp | 2 -
be/src/storage/row_cursor.h | 2 -
be/src/storage/rowid_conversion.h | 2 -
be/src/storage/rowset/beta_rowset.cpp | 2 -
be/src/storage/rowset/beta_rowset_reader.cpp | 2 -
be/src/storage/rowset/beta_rowset_writer.cpp | 2 -
be/src/storage/rowset/rowset.cpp | 4 -
be/src/storage/rowset/rowset_meta.cpp | 4 -
be/src/storage/rowset/rowset_meta.h | 3 -
be/src/storage/rowset/rowset_meta_manager.cpp | 2 -
be/src/storage/rowset/segcompaction.cpp | 2 -
be/src/storage/rowset_builder.cpp | 2 -
be/src/storage/schema.h | 4 -
be/src/storage/schema_change/schema_change.cpp | 4 -
be/src/storage/segment/binary_dict_page.cpp | 2 -
be/src/storage/segment/binary_plain_page.h | 2 -
be/src/storage/segment/binary_plain_page_v2.h | 2 -
be/src/storage/segment/binary_prefix_page.cpp | 2 -
be/src/storage/segment/bitshuffle_page.h | 2 -
be/src/storage/segment/column_reader.cpp | 2 -
be/src/storage/segment/column_reader.h | 2 -
be/src/storage/segment/column_reader_cache.cpp | 4 -
be/src/storage/segment/column_writer.cpp | 3 -
be/src/storage/segment/frame_of_reference_page.h | 2 -
be/src/storage/segment/page_io.cpp | 2 -
be/src/storage/segment/plain_page.h | 2 -
be/src/storage/segment/rle_page.h | 2 -
be/src/storage/segment/row_ranges.h | 2 -
be/src/storage/segment/segment.cpp | 2 -
be/src/storage/segment/segment_iterator.cpp | 2 -
be/src/storage/segment/segment_loader.h | 2 -
be/src/storage/segment/segment_writer.cpp | 3 -
.../variant/binary_column_extract_iterator.h | 4 -
.../segment/variant/binary_column_reader.cpp | 3 -
.../storage/segment/variant/binary_column_reader.h | 3 -
.../segment/variant/hierarchical_data_iterator.cpp | 4 -
.../segment/variant/hierarchical_data_iterator.h | 4 -
.../variant/sparse_column_merge_iterator.cpp | 4 -
.../segment/variant/sparse_column_merge_iterator.h | 4 -
.../segment/variant/variant_column_reader.cpp | 4 -
.../segment/variant/variant_column_reader.h | 4 -
.../segment/variant/variant_column_writer_impl.cpp | 4 -
.../segment/variant/variant_column_writer_impl.h | 4 -
.../variant_doc_snpashot_compact_iterator.h | 3 -
.../variant/variant_external_meta_reader.cpp | 4 -
.../segment/variant/variant_external_meta_reader.h | 4 -
.../storage/segment/variant/variant_statistics.h | 3 -
.../variant_streaming_compaction_writer.cpp | 4 -
.../variant/variant_streaming_compaction_writer.h | 4 -
.../segment/variant/variant_writer_helpers.h | 4 -
.../storage/segment/variant_stats_calculator.cpp | 4 -
be/src/storage/segment/vertical_segment_writer.cpp | 4 -
be/src/storage/snapshot/snapshot_manager.cpp | 2 -
be/src/storage/storage_engine.cpp | 2 -
be/src/storage/tablet/base_tablet.cpp | 1 -
be/src/storage/tablet/tablet.cpp | 2 -
be/src/storage/tablet/tablet.h | 2 -
be/src/storage/tablet/tablet_manager.cpp | 2 -
be/src/storage/tablet/tablet_meta.cpp | 2 -
be/src/storage/tablet/tablet_meta.h | 2 -
be/src/storage/tablet/tablet_meta_manager.cpp | 2 -
be/src/storage/tablet/tablet_reader.cpp | 2 -
be/src/storage/tablet/tablet_schema.cpp | 2 -
be/src/storage/tablet/tablet_schema.h | 3 -
be/src/storage/tablet_info.cpp | 2 -
be/src/storage/tablet_info.h | 2 -
.../storage/task/engine_storage_migration_task.cpp | 2 -
be/src/storage/task/index_builder.cpp | 2 -
be/src/storage/types.h | 2 -
be/src/storage/utils.cpp | 2 -
be/src/storage/version_graph.cpp | 2 -
be/src/util/bit_packing.inline.h | 2 -
be/src/util/bit_stream_utils.h | 2 -
be/src/util/bit_stream_utils.inline.h | 2 -
be/src/util/bitmap.h | 2 -
be/src/util/bitmap_intersect.h | 2 -
be/src/util/block_compression.cpp | 2 -
be/src/util/blocking_priority_queue.hpp | 2 -
be/src/util/blocking_queue.hpp | 2 -
be/src/util/brpc_client_cache.cpp | 2 -
be/src/util/brpc_client_cache.h | 2 -
be/src/util/coding.cpp | 2 -
be/src/util/coding.h | 2 -
be/src/util/countdown_latch.h | 2 -
be/src/util/cpu_info.cpp | 4 +-
be/src/util/date_func.cpp | 2 -
be/src/util/decompressor.cpp | 2 -
be/src/util/decompressor.h | 2 -
be/src/util/disk_info.cpp | 4 -
be/src/util/disk_info.h | 4 -
be/src/util/frame_of_reference_coding.cpp | 2 -
be/src/util/frame_of_reference_coding.h | 2 -
be/src/util/hash/city.cc | 1 -
be/src/util/hash/murmur_hash3.cpp | 2 -
be/src/util/hash_util.hpp | 3 -
be/src/util/io_helper.h | 3 -
be/src/util/jni-util.cpp | 2 -
be/src/util/json/json_parser.cpp | 3 -
be/src/util/json/path_in_data.cpp | 4 -
be/src/util/json/simd_json_parser.h | 4 -
be/src/util/jsonb_parser_simd.h | 2 -
be/src/util/lru_cache.cpp | 1 -
be/src/util/lru_cache.h | 2 -
be/src/util/lzo_decompressor.cpp | 2 -
be/src/util/network_util.cpp | 2 -
be/src/util/parse_util.cpp | 1 -
be/src/util/perf_counters.cpp | 1 -
be/src/util/raw_value.h | 2 -
be/src/util/rle_encoding.h | 2 -
be/src/util/simd/bits.h | 2 -
be/src/util/simd/reverse_copy_bytes.h | 2 -
be/src/util/slice.h | 2 -
be/src/util/string_search.hpp | 2 -
be/src/util/tdigest.h | 2 -
be/src/util/thrift_client.h | 3 +
be/src/util/time_lut.cpp | 2 -
be/src/util/timezone_utils.cpp | 2 -
be/src/util/uid_util.cpp | 2 -
be/src/util/url_parser.cpp | 2 -
be/src/util/zlib.cpp | 2 -
be/test/cloud/cloud_tablet_test.cpp | 248 +
be/test/core/column/column_string_test.cpp | 2 +-
.../schema_role_mappings_scanner_test.cpp | 40 +
.../exprs/function/function_money_format_test.cpp | 2 +-
.../exprs/function/function_sub_replace_test.cpp | 2 +-
.../workload_group/workload_group_manager_test.cpp | 516 ++
build-support/run-clang-tidy.sh | 375 ++
cloud/src/resource-manager/resource_manager.cpp | 15 +-
docker/runtime/doris-compose/cluster.py | 9 +-
.../main/java/org/apache/doris/common/Config.java | 2 +-
.../java/org/apache/doris/common/LdapConfig.java | 31 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 5 +-
.../apache/doris/alter/SchemaChangeHandler.java | 105 +-
.../org/apache/doris/analysis/ArithmeticExpr.java | 6 +-
.../apache/doris/analysis/ColumnAccessPath.java | 99 +
.../doris/analysis/ColumnAccessPathType.java | 14 +-
.../org/apache/doris/analysis/DescriptorTable.java | 36 +-
.../analysis/DescriptorToThriftConverter.java | 142 +
.../apache/doris/analysis/ExprToThriftVisitor.java | 19 +-
.../org/apache/doris/analysis/FunctionParams.java | 18 -
.../org/apache/doris/analysis/OrderByElement.java | 12 +-
.../org/apache/doris/analysis/SchemaTableType.java | 3 +-
.../org/apache/doris/analysis/SlotDescriptor.java | 87 +-
.../java/org/apache/doris/analysis/SlotRef.java | 2 +-
.../org/apache/doris/analysis/TupleDescriptor.java | 27 +-
.../org/apache/doris/backup/BackupHandler.java | 10 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 11 +
.../apache/doris/datasource/FileQueryScanNode.java | 8 -
.../doris/httpv2/rest/TableQueryPlanAction.java | 3 +-
.../org/apache/doris/info/BaseTableRefInfo.java | 48 -
.../java/org/apache/doris/info/TableRefInfo.java | 25 +-
.../mysql/authenticate/AuthenticatorManager.java | 17 +
.../mysql/authenticate/ldap/LdapAuthenticator.java | 38 +-
.../doris/mysql/authenticate/ldap/LdapClient.java | 69 +-
.../doris/mysql/authenticate/ldap/LdapManager.java | 52 +-
.../doris/mysql/privilege/UserPropertyMgr.java | 5 +
.../glue/translator/PhysicalPlanTranslator.java | 22 +-
.../glue/translator/RuntimeFilterTranslator.java | 2 +-
.../nereids/load/NereidsStreamLoadPlanner.java | 3 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 16 +-
.../properties/ChildrenPropertiesRegulator.java | 22 +-
.../rules/SimplifyConditionalFunction.java | 26 +-
.../rewrite/AccessPathExpressionCollector.java | 30 +-
.../nereids/rules/rewrite/AccessPathInfo.java | 18 +-
.../nereids/rules/rewrite/NestedColumnPruning.java | 97 +-
.../nereids/rules/rewrite/SlotTypeReplacer.java | 52 +-
.../nereids/trees/expressions/SlotReference.java | 30 +-
.../trees/plans/commands/info/DropIndexOp.java | 42 +
.../trees/plans/commands/info/IndexDefinition.java | 14 +-
.../org/apache/doris/planner/AnalyticEvalNode.java | 25 +-
.../org/apache/doris/planner/JoinNodeBase.java | 3 -
.../org/apache/doris/planner/OlapScanNode.java | 20 +-
.../org/apache/doris/planner/OlapTableSink.java | 5 +-
.../java/org/apache/doris/planner/PlanNode.java | 31 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 5 +-
.../org/apache/doris/qe/CoordinatorContext.java | 5 +-
.../apache/doris/qe/ShortCircuitQueryContext.java | 3 +-
.../apache/doris/service/FrontendServiceImpl.java | 11 +-
.../doris/tablefunction/MetadataGenerator.java | 77 +
.../org/apache/doris/task/AlterReplicaTask.java | 3 +-
.../org/apache/doris/alter/IndexChangeJobTest.java | 125 +
.../analysis/DescriptorToThriftConverterTest.java | 358 ++
.../org/apache/doris/analysis/ExprToSqlTest.java | 10 +-
.../org/apache/doris/catalog/SchemaTableTest.java | 13 +
.../doris/mysql/authenticate/TestLogAppender.java | 77 +
.../authenticate/ldap/LdapAuthenticatorTest.java | 28 +
.../mysql/authenticate/ldap/LdapClientTest.java | 65 +
.../mysql/authenticate/ldap/LdapManagerTest.java | 31 +
.../rules/SimplifyConditionalFunctionTest.java | 21 +
.../rules/rewrite/AggregateUnionPlanTest.java | 117 +
.../rules/rewrite/PruneNestedColumnTest.java | 58 +-
.../rules/rewrite/VariantPruningLogicTest.java | 26 +-
.../org/apache/doris/planner/PlanNodeTest.java | 4 +-
.../doris/service/FrontendServiceImplTest.java | 124 +
fe/pom.xml | 6 +-
gensrc/proto/cloud.proto | 7 +-
gensrc/thrift/Descriptors.thrift | 1 +
gensrc/thrift/FrontendService.thrift | 1 +
.../data/ann_index_p0/ann_index_on_mow.out | 31 +
.../tpcds_sf100/noStatsRfPrune/query75.out | 117 +-
.../tpcds_sf100/no_stats_shape/query75.out | 117 +-
.../shape_check/tpcds_sf10t_orc/shape/query75.out | 117 +-
.../suites/ann_index_p0/ann_index_on_mow.groovy | 66 +
.../ann_index_p0/build_ann_index_test.groovy | 59 +-
.../ann_index_p0/create_ann_index_test.groovy | 63 +-
.../create_tbl_with_ann_index_test.groovy | 22 +
.../auth_p0/test_role_mapping_system_table.groovy | 123 +
.../hive_on_hms_and_dlf.groovy | 24 +-
.../test_drop_index_on_partition.groovy | 273 +
tools/tpch-tools/ddl/create-tpch-tables-sf1000.sql | 2 +-
1228 files changed, 10521 insertions(+), 8593 deletions(-)
create mode 100644 .claude/skills/be-code-style/SKILL.md
create mode 100644 .claude/skills/clang-tidy-check/SKILL.md
create mode 100644 .claude/skills/fe-code-style/SKILL.md
create mode 100644 be/benchmark/benchmark_hybrid_set.hpp
delete mode 100644 be/src/common/compile_check_begin.h
delete mode 100644 be/src/exprs/function/function_string.h
create mode 100644 be/src/exprs/function/function_string_basic.cpp
create mode 100644 be/src/exprs/function/function_string_concat.h
create mode 100644 be/src/exprs/function/function_string_digest.cpp
create mode 100644 be/src/exprs/function/function_string_format.h
create mode 100644 be/src/exprs/function/function_string_mask.cpp
create mode 100644 be/src/exprs/function/function_string_misc.cpp
create mode 100644 be/src/exprs/function/function_string_replace.h
create mode 100644 be/src/exprs/function/function_string_search.cpp
create mode 100644 be/src/exprs/function/function_string_url.cpp
copy be/src/information_schema/{schema_authentication_integrations_scanner.cpp
=> schema_role_mappings_scanner.cpp} (69%)
copy be/src/{format/parquet/vparquet_file_metadata.h =>
information_schema/schema_role_mappings_scanner.h} (54%)
create mode 100644
be/test/exec/schema_scanner/schema_role_mappings_scanner_test.cpp
create mode 100755 build-support/run-clang-tidy.sh
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ColumnAccessPath.java
rename be/src/common/compile_check_end.h =>
fe/fe-core/src/main/java/org/apache/doris/analysis/ColumnAccessPathType.java
(77%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/DescriptorToThriftConverter.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/info/BaseTableRefInfo.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/DescriptorToThriftConverterTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mysql/authenticate/TestLogAppender.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/AggregateUnionPlanTest.java
create mode 100644 regression-test/data/ann_index_p0/ann_index_on_mow.out
create mode 100644 regression-test/suites/ann_index_p0/ann_index_on_mow.groovy
create mode 100644
regression-test/suites/auth_p0/test_role_mapping_system_table.groovy
create mode 100644
regression-test/suites/inverted_index_p0/index_change/test_drop_index_on_partition.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
