This is an automated email from the ASF dual-hosted git repository.
caiconghui pushed a change to branch table_lock
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git.
discard 1585a01 fix unit test failed for SelectStmt
discard 220ac11 Fix dead lock bug
discard a359225 fix
discard 6cede9d fix
discard 3d836aa fix
discard 32f360e remove useless db read lock and change some db read lock to
table locks
discard ca48518 remove useless db read lock
discard 277c8ad remove useless code of dropTableWithLock for Database
discard 2db6bfb use MetadataLockUtils to lock table when finish transaction
discard 717af00 Add unit test for MetaLockUtils
discard c703d8e Fix save image lock
discard c781a92 Fix SparkLoadJobTest Failed
discard f324700 fix unit test failed
discard f35bdcf fix unittest failed
discard 5e0ed1f fix conflict for table lock and db lock
discard 56b5229 fix unittest failed
discard 3e2be1f Change db level lock to table level lock for query
discard 65bc38c Fix unittest for AlterTest failed
discard 6c62042 Add MetaLockUtils and fix some table lock level
discard 6171a42 fix
discard 52183db fix unit test failed for AlterTest
discard b224b51 fix ReportHandler
discard 805837b fix conflict after rebasing mater
discard 347c5d9 fix test
discard 32731c0 fix DeleteHandler
discard 9c207f0 fix
discard edd2638 fix SchemaChangeJobV2
discard 0105d87 fix cancel
discard c5c579f fix RollupJobV2
discard 2461be0 Fix RollupJob
discard 9821229 Fix AlterJobV2 and MaterializedViewHandler
discard e1817c8 fix Alter Class
discard 7467b70 modify .gitignore content
discard 4cfe529 fix merge
discard 4fe56fa add null check for olap_table
discard b80fcec fix unit test
discard 212c816 finish to replace db lock by table lock
discard fc8f28c Continue to use table lock to replace db lock
discard 247d7f0 use table lock to replace db lock
discard e1e9893 remove some unused temp code
discard f2ac4a6 use table write lock to replace db write lock
discard c2daf4a Use table lock to replace db lock in some functions
discard 589c1d3 Support table level read and write lock
add b7b1d5e [Refactor] Short circuit return to avoid meaningless loop
(#4933)
add 2682712 [Bug] Fix be ut compile failed and core in delta_writer_test
when ulimit < 60000. (#4941)
add 10e1e29 Remove header file common/names.h (#4945)
add 68db176 [Refator]Modify code write error (#4950)
add 0493eb1 [Optimize] optimize host selection strategy (#4914)
add 3b56b60 Show fe commit hash on proc (#4943)
add 55ce88d [Schema change] Support More column type in schema change
(#4938)
add c6bc30e [Bug] Fix httpv2 append extra useless information in
get_small_file api (#4953)
add cb749ce [Improvement] Add parquet file name to the error message
(#4954)
add 2331ce1 [Bug]Parquet map/list/struct structure recognize (#4968)
add 2e9c8dd [Doris On ES][Bug-Fix] fix problem for selecting random be
(#4972)
add f1248cb [BUG] Fix colocate balance bug when there is decommissioned
be (#4955)
add 4c63dc0 [Metric] Add metrics for compaction permits and log for
compaction merge (#4893)
add f944bf4 [Compile][Bug] Fix FE compilation bug (#4979)
add 6fedf58 [CodeFormat] Clang-format cpp sources (#4965)
add d7225d6 [CodeFormat] Add clang-format script (#4934)
add bb36de5 [Bug] Fix locate bug when start_pos larger than str len
(#4975)
add 27ef5b4 [Bug] Use the right queryId to audit master only query in non
master (#4978)
add ec7e1c6 [Refactor] Execute 'pick rowsets' before applying for permits
for a compaction task (#4891)
add 99404df [Bug][Compaction] Fix bug that output rowset is not deleted
after compaction failure (#4964)
add df1f06e Optimized the read performance of the table when have multi
versions (#4958)
add af06adb [Doris On ES][Bug-fix] fix boolean predicate pushdown manner
(#4990)
add 0658a7c Support table level read and write lock
add 25ea02b Use table lock to replace db lock in some functions
add 65bb386 use table write lock to replace db write lock
add 2c42918 remove some unused temp code
add c6b02ee use table lock to replace db lock
add 5f91fff Continue to use table lock to replace db lock
add b047b86 finish to replace db lock by table lock
add 253a0eb fix unit test
add 50b2b7f add null check for olap_table
add a32ac35 fix merge
add 635f30d modify .gitignore content
add 14c4fc0 fix Alter Class
add 362ed72 Fix AlterJobV2 and MaterializedViewHandler
add 43057f0 Fix RollupJob
add 3d8b947 fix RollupJobV2
add 5de5ae2 fix cancel
add 9503724 fix SchemaChangeJobV2
add 5a8710c fix
add 0ea4d73 fix DeleteHandler
add 38e184b fix test
add d525f65 fix conflict after rebasing mater
add 95c5c36 fix ReportHandler
add d6f3c1f fix unit test failed for AlterTest
add 38f8fe5 fix
add 379c0b0 Add MetaLockUtils and fix some table lock level
add f1d5166 Fix unittest for AlterTest failed
add e313da3 Change db level lock to table level lock for query
add 0157ed9 fix unittest failed
add 574409f fix conflict for table lock and db lock
add b5764f2 fix unittest failed
add 7c56882 fix unit test failed
add aa8734a Fix SparkLoadJobTest Failed
add 9a87f3d Fix save image lock
add d0aa337 Add unit test for MetaLockUtils
add eb34a2e use MetadataLockUtils to lock table when finish transaction
add 2b74749 remove useless code of dropTableWithLock for Database
add 03d0161 remove useless db read lock
add 4364c77 remove useless db read lock and change some db read lock to
table locks
add b81a6fb fix
add df2da6a fix
add 965ad18 fix
add 260f49e Fix dead lock bug
add 7ec87e7 fix unit test failed for SelectStmt
add f805967 Fix by review
add b54eae6 Add table lock when update BackendReportVersion in
SystemInfoService
add 419d116 change db level lock to table lock level in http2
add 1485ab0 Fix broker load failed bug and add unit test for db
add 0df43a0 fix
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 (1585a01)
\
N -- N -- N refs/heads/table_lock (0df43a0)
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:
.gitignore | 13 +-
be/src/agent/agent_server.cpp | 93 +-
be/src/agent/agent_server.h | 5 +-
be/src/agent/cgroups_mgr.cpp | 309 +-
be/src/agent/cgroups_mgr.h | 69 +-
be/src/agent/heartbeat_server.cpp | 63 +-
be/src/agent/heartbeat_server.h | 20 +-
be/src/agent/pusher.cpp | 48 +-
be/src/agent/status.h | 4 +-
be/src/agent/task_worker_pool.cpp | 120 +-
be/src/agent/task_worker_pool.h | 126 +-
be/src/agent/topic_listener.h | 10 +-
be/src/agent/topic_subscriber.cpp | 13 +-
be/src/agent/topic_subscriber.h | 5 +-
be/src/agent/user_resource_listener.cpp | 73 +-
be/src/agent/user_resource_listener.h | 17 +-
be/src/agent/utils.cpp | 76 +-
be/src/agent/utils.h | 33 +-
be/src/common/atomic.h | 44 +-
be/src/common/compiler_util.h | 3 +-
be/src/common/config.h | 1128 ++--
be/src/common/configbase.cpp | 36 +-
be/src/common/configbase.h | 3 +-
be/src/common/daemon.cpp | 117 +-
be/src/common/daemon.h | 2 +-
be/src/common/global_types.h | 2 +-
be/src/common/hdfs.h | 1 -
be/src/common/logconfig.cpp | 35 +-
be/src/common/logging.h | 43 +-
be/src/common/names.h | 6 +-
be/src/common/object_pool.h | 18 +-
be/src/common/resource_tls.cpp | 2 +-
be/src/common/resource_tls.h | 2 +-
be/src/common/status.cpp | 9 +-
be/src/common/status.h | 167 +-
be/src/common/utils.h | 4 +-
be/src/env/env.h | 12 +-
be/src/env/env_posix.cpp | 113 +-
be/src/env/env_util.cpp | 11 +-
be/src/exec/aggregation_node.cpp | 101 +-
be/src/exec/aggregation_node.h | 11 +-
be/src/exec/aggregation_node_ir.cpp | 4 +-
be/src/exec/analytic_eval_node.cpp | 171 +-
be/src/exec/analytic_eval_node.h | 7 +-
be/src/exec/base_scanner.cpp | 46 +-
be/src/exec/base_scanner.h | 19 +-
be/src/exec/blocking_join_node.cpp | 23 +-
be/src/exec/blocking_join_node.h | 26 +-
be/src/exec/broker_reader.cpp | 4 +-
be/src/exec/broker_reader.h | 21 +-
be/src/exec/broker_scan_node.cpp | 147 +-
be/src/exec/broker_scan_node.h | 11 +-
be/src/exec/broker_scanner.cpp | 134 +-
be/src/exec/broker_scanner.h | 40 +-
be/src/exec/broker_writer.cpp | 59 +-
be/src/exec/broker_writer.h | 12 +-
be/src/exec/buffered_reader.cpp | 11 +-
be/src/exec/buffered_reader.h | 14 +-
be/src/exec/cross_join_node.cpp | 15 +-
be/src/exec/cross_join_node.h | 8 +-
be/src/exec/csv_scan_node.cpp | 230 +-
be/src/exec/csv_scan_node.h | 29 +-
be/src/exec/csv_scanner.cpp | 105 +-
be/src/exec/csv_scanner.h | 2 +-
be/src/exec/data_sink.cpp | 52 +-
be/src/exec/data_sink.h | 15 +-
be/src/exec/decompressor.cpp | 88 +-
be/src/exec/decompressor.h | 101 +-
be/src/exec/empty_set_node.cpp | 13 +-
be/src/exec/empty_set_node.h | 3 +-
be/src/exec/es/es_predicate.cpp | 227 +-
be/src/exec/es/es_predicate.h | 111 +-
be/src/exec/es/es_query_builder.cpp | 350 +-
be/src/exec/es/es_query_builder.h | 27 +-
be/src/exec/es/es_scan_reader.cpp | 61 +-
be/src/exec/es/es_scan_reader.h | 21 +-
be/src/exec/es/es_scroll_parser.cpp | 439 +-
be/src/exec/es/es_scroll_parser.h | 17 +-
be/src/exec/es/es_scroll_query.cpp | 31 +-
be/src/exec/es/es_scroll_query.h | 18 +-
be/src/exec/es_http_scan_node.cpp | 106 +-
be/src/exec/es_http_scan_node.h | 17 +-
be/src/exec/es_http_scanner.cpp | 13 +-
be/src/exec/es_http_scanner.h | 37 +-
be/src/exec/es_scan_node.cpp | 399 +-
be/src/exec/es_scan_node.h | 16 +-
be/src/exec/except_node.cpp | 6 +-
be/src/exec/exchange_node.cpp | 54 +-
be/src/exec/exchange_node.h | 12 +-
be/src/exec/exec_node.cpp | 184 +-
be/src/exec/exec_node.h | 139 +-
be/src/exec/file_reader.h | 7 +-
be/src/exec/file_writer.h | 3 +-
be/src/exec/hash_join_node.cpp | 138 +-
be/src/exec/hash_join_node.h | 34 +-
be/src/exec/hash_table.cpp | 53 +-
be/src/exec/hash_table.h | 100 +-
be/src/exec/intersect_node.cpp | 6 +-
be/src/exec/json_scanner.cpp | 258 +-
be/src/exec/json_scanner.h | 81 +-
be/src/exec/line_reader.h | 5 +-
be/src/exec/local_file_reader.cpp | 31 +-
be/src/exec/local_file_reader.h | 8 +-
be/src/exec/local_file_writer.cpp | 20 +-
be/src/exec/lzo_decompressor.cpp | 91 +-
be/src/exec/merge_join_node.cpp | 65 +-
be/src/exec/merge_join_node.h | 8 +-
be/src/exec/merge_node.cpp | 63 +-
be/src/exec/merge_node.h | 7 +-
be/src/exec/mysql_scan_node.cpp | 47 +-
be/src/exec/mysql_scan_node.h | 10 +-
be/src/exec/mysql_scanner.cpp | 30 +-
be/src/exec/mysql_scanner.h | 17 +-
be/src/exec/odbc_scan_node.cpp | 35 +-
be/src/exec/odbc_scan_node.h | 11 +-
be/src/exec/odbc_scanner.cpp | 92 +-
be/src/exec/odbc_scanner.h | 32 +-
be/src/exec/olap_common.cpp | 17 +-
be/src/exec/olap_common.h | 247 +-
be/src/exec/olap_rewrite_node.cpp | 58 +-
be/src/exec/olap_rewrite_node.h | 4 +-
be/src/exec/olap_scan_node.cpp | 361 +-
be/src/exec/olap_scan_node.h | 35 +-
be/src/exec/olap_scanner.cpp | 141 +-
be/src/exec/olap_scanner.h | 56 +-
be/src/exec/olap_utils.h | 52 +-
be/src/exec/orc_scanner.cpp | 361 +-
be/src/exec/orc_scanner.h | 6 +-
be/src/exec/parquet_reader.cpp | 586 ++-
be/src/exec/parquet_reader.h | 41 +-
be/src/exec/parquet_scanner.cpp | 102 +-
be/src/exec/parquet_scanner.h | 23 +-
be/src/exec/parquet_writer.cpp | 19 +-
be/src/exec/parquet_writer.h | 25 +-
be/src/exec/partitioned_aggregation_node.cc | 2439 +++++----
be/src/exec/partitioned_aggregation_node.h | 1086 ++--
be/src/exec/partitioned_aggregation_node_ir.cc | 381 +-
be/src/exec/partitioned_hash_table.cc | 806 ++-
be/src/exec/partitioned_hash_table.h | 1657 +++---
be/src/exec/partitioned_hash_table.inline.h | 572 +-
be/src/exec/partitioned_hash_table_ir.cc | 9 +-
be/src/exec/pl_task_root.cpp | 23 +-
be/src/exec/pl_task_root.h | 9 +-
be/src/exec/plain_text_line_reader.cpp | 97 +-
be/src/exec/plain_text_line_reader.h | 19 +-
be/src/exec/read_write_util.cpp | 2 +-
be/src/exec/read_write_util.h | 25 +-
be/src/exec/repeat_node.cpp | 74 +-
be/src/exec/repeat_node.h | 2 +-
be/src/exec/row_batch_list.h | 30 +-
be/src/exec/scan_node.cpp | 22 +-
be/src/exec/scan_node.h | 25 +-
be/src/exec/scanner_ir.cpp | 27 +-
be/src/exec/schema_scan_node.cpp | 57 +-
be/src/exec/schema_scan_node.h | 8 +-
be/src/exec/schema_scanner.cpp | 61 +-
be/src/exec/schema_scanner.h | 32 +-
.../schema_scanner/schema_charsets_scanner.cpp | 52 +-
.../exec/schema_scanner/schema_charsets_scanner.h | 13 +-
.../schema_scanner/schema_collations_scanner.cpp | 65 +-
.../schema_scanner/schema_collations_scanner.h | 15 +-
.../exec/schema_scanner/schema_columns_scanner.cpp | 352 +-
.../exec/schema_scanner/schema_columns_scanner.h | 17 +-
.../exec/schema_scanner/schema_dummy_scanner.cpp | 20 +-
be/src/exec/schema_scanner/schema_dummy_scanner.h | 8 +-
be/src/exec/schema_scanner/schema_helper.cpp | 129 +-
be/src/exec/schema_scanner/schema_helper.h | 66 +-
.../schema_schema_privileges_scanner.cpp | 55 +-
.../schema_schema_privileges_scanner.h | 10 +-
.../schema_scanner/schema_schemata_scanner.cpp | 59 +-
.../exec/schema_scanner/schema_schemata_scanner.h | 8 +-
.../schema_table_privileges_scanner.cpp | 58 +-
.../schema_table_privileges_scanner.h | 10 +-
.../exec/schema_scanner/schema_tables_scanner.cpp | 161 +-
be/src/exec/schema_scanner/schema_tables_scanner.h | 8 +-
.../schema_user_privileges_scanner.cpp | 50 +-
.../schema_user_privileges_scanner.h | 10 +-
.../schema_scanner/schema_variables_scanner.cpp | 49 +-
.../exec/schema_scanner/schema_variables_scanner.h | 15 +-
.../exec/schema_scanner/schema_views_scanner.cpp | 94 +-
be/src/exec/schema_scanner/schema_views_scanner.h | 8 +-
be/src/exec/select_node.cpp | 23 +-
be/src/exec/select_node.h | 2 +-
be/src/exec/set_operation_node.cpp | 4 +-
be/src/exec/set_operation_node.h | 1 -
be/src/exec/sort_exec_exprs.cpp | 31 +-
be/src/exec/sort_exec_exprs.h | 4 +-
be/src/exec/spill_sort_node.cc | 32 +-
be/src/exec/spill_sort_node.h | 2 +-
be/src/exec/tablet_info.cpp | 70 +-
be/src/exec/tablet_info.h | 58 +-
be/src/exec/tablet_sink.cpp | 19 +-
be/src/exec/tablet_sink.h | 4 +-
be/src/exec/text_converter.cpp | 9 +-
be/src/exec/text_converter.h | 6 +-
be/src/exec/topn_node.cpp | 60 +-
be/src/exec/topn_node.h | 11 +-
be/src/exec/union_node.cpp | 62 +-
be/src/exec/union_node.h | 17 +-
be/src/exec/union_node_ir.cpp | 11 +-
be/src/exprs/agg_fn.cc | 273 +-
be/src/exprs/agg_fn.h | 201 +-
be/src/exprs/agg_fn_evaluator.cpp | 381 +-
be/src/exprs/agg_fn_evaluator.h | 137 +-
be/src/exprs/aggregate_functions.cpp | 1351 +++--
be/src/exprs/aggregate_functions.h | 246 +-
be/src/exprs/anyval_util.cpp | 23 +-
be/src/exprs/anyval_util.h | 128 +-
be/src/exprs/arithmetic_expr.cpp | 121 +-
be/src/exprs/arithmetic_expr.h | 79 +-
be/src/exprs/binary_predicate.cpp | 197 +-
be/src/exprs/binary_predicate.h | 50 +-
be/src/exprs/bitmap_function.cpp | 366 +-
be/src/exprs/bitmap_function.h | 30 +-
be/src/exprs/case_expr.cpp | 118 +-
be/src/exprs/case_expr.h | 31 +-
be/src/exprs/cast_expr.cpp | 20 +-
be/src/exprs/cast_expr.h | 34 +-
be/src/exprs/cast_functions.cpp | 230 +-
be/src/exprs/cast_functions.h | 2 +-
be/src/exprs/compound_predicate.cpp | 11 +-
be/src/exprs/compound_predicate.h | 26 +-
be/src/exprs/conditional_functions.cpp | 14 +-
be/src/exprs/conditional_functions.h | 25 +-
be/src/exprs/conditional_functions_ir.cpp | 67 +-
be/src/exprs/decimal_operators.cpp | 136 +-
be/src/exprs/decimal_operators.h | 49 +-
be/src/exprs/decimalv2_operators.cpp | 146 +-
be/src/exprs/decimalv2_operators.h | 49 +-
be/src/exprs/encryption_functions.cpp | 47 +-
be/src/exprs/encryption_functions.h | 21 +-
be/src/exprs/es_functions.cpp | 13 +-
be/src/exprs/es_functions.h | 9 +-
be/src/exprs/expr.cpp | 369 +-
be/src/exprs/expr.h | 127 +-
be/src/exprs/expr_context.cpp | 137 +-
be/src/exprs/expr_context.h | 24 +-
be/src/exprs/expr_ir.cpp | 8 +-
be/src/exprs/expr_value.h | 58 +-
be/src/exprs/grouping_sets_functions.cpp | 14 +-
be/src/exprs/grouping_sets_functions.h | 11 +-
be/src/exprs/hash_functions.cpp | 8 +-
be/src/exprs/hash_functions.h | 9 +-
be/src/exprs/hll_function.cpp | 15 +-
be/src/exprs/hll_function.h | 4 +-
be/src/exprs/hll_hash_function.cpp | 8 +-
be/src/exprs/hll_hash_function.h | 4 +-
be/src/exprs/hybrid_map.h | 17 +-
be/src/exprs/hybrid_set.cpp | 26 +-
be/src/exprs/hybrid_set.h | 94 +-
be/src/exprs/in_predicate.cpp | 31 +-
be/src/exprs/in_predicate.h | 28 +-
be/src/exprs/info_func.cpp | 13 +-
be/src/exprs/info_func.h | 12 +-
be/src/exprs/is_null_predicate.cpp | 10 +-
be/src/exprs/is_null_predicate.h | 7 +-
be/src/exprs/json_functions.cpp | 127 +-
be/src/exprs/json_functions.h | 91 +-
be/src/exprs/like_predicate.cpp | 196 +-
be/src/exprs/like_predicate.h | 137 +-
be/src/exprs/literal.cpp | 25 +-
be/src/exprs/literal.h | 6 +-
be/src/exprs/math_functions.cpp | 358 +-
be/src/exprs/math_functions.h | 255 +-
be/src/exprs/new_agg_fn_evaluator.cc | 853 ++-
be/src/exprs/new_agg_fn_evaluator.h | 481 +-
be/src/exprs/new_agg_fn_evaluator_ir.cc | 4 +-
be/src/exprs/new_in_predicate.cpp | 133 +-
be/src/exprs/new_in_predicate.h | 403 +-
be/src/exprs/null_literal.cpp | 6 +-
be/src/exprs/null_literal.h | 5 +-
be/src/exprs/operators.cpp | 153 +-
be/src/exprs/operators.h | 410 +-
be/src/exprs/predicate.h | 4 +-
be/src/exprs/scalar_fn_call.cpp | 266 +-
be/src/exprs/scalar_fn_call.h | 20 +-
be/src/exprs/slot_ref.cpp | 59 +-
be/src/exprs/slot_ref.h | 36 +-
be/src/exprs/string_functions.cpp | 214 +-
be/src/exprs/string_functions.h | 219 +-
be/src/exprs/time_operators.cpp | 52 +-
be/src/exprs/time_operators.h | 3 +-
be/src/exprs/timestamp_functions.cpp | 528 +-
be/src/exprs/timestamp_functions.h | 646 +--
be/src/exprs/tuple_is_null_predicate.cpp | 15 +-
be/src/exprs/tuple_is_null_predicate.h | 9 +-
be/src/exprs/udf_builtins.cpp | 20 +-
be/src/exprs/udf_builtins.h | 34 +-
be/src/geo/geo_common.cpp | 2 +-
be/src/geo/geo_common.h | 2 +-
be/src/geo/geo_functions.cpp | 49 +-
be/src/geo/geo_functions.h | 53 +-
be/src/geo/geo_types.cpp | 19 +-
be/src/geo/geo_types.h | 32 +-
be/src/geo/wkt_parse.cpp | 4 +-
be/src/geo/wkt_parse.h | 2 +-
be/src/geo/wkt_parse_ctx.h | 1 -
be/src/geo/wkt_parse_type.h | 13 +-
be/src/gutil/arm_instruction_set_select.h | 46 +-
be/src/gutil/atomic_refcount.h | 96 +-
be/src/gutil/atomicops-internals-gcc.h | 161 +-
be/src/gutil/atomicops-internals-tsan.h | 211 +-
be/src/gutil/atomicops-internals-x86.cc | 101 +-
be/src/gutil/atomicops-internals-x86.h | 508 +-
be/src/gutil/atomicops.h | 170 +-
be/src/gutil/basictypes.h | 13 +-
be/src/gutil/bits.cc | 126 +-
be/src/gutil/bits.h | 336 +-
be/src/gutil/casts.h | 253 +-
be/src/gutil/charmap.h | 90 +-
be/src/gutil/cpu.cc | 421 +-
be/src/gutil/cpu.h | 141 +-
be/src/gutil/cycleclock-inl.h | 167 +-
be/src/gutil/dynamic_annotations.h | 713 ++-
be/src/gutil/endian.h | 483 +-
be/src/gutil/gscoped_ptr.h | 1158 ++---
be/src/gutil/hash/builtin_type_hash.h | 80 +-
be/src/gutil/hash/city.cc | 433 +-
be/src/gutil/hash/city.h | 17 +-
be/src/gutil/hash/hash.cc | 277 +-
be/src/gutil/hash/hash.h | 315 +-
be/src/gutil/hash/hash128to64.h | 18 +-
be/src/gutil/hash/jenkins.cc | 367 +-
be/src/gutil/hash/jenkins.h | 9 +-
be/src/gutil/hash/jenkins_lookup2.h | 143 +-
be/src/gutil/hash/legacy_hash.h | 41 +-
be/src/gutil/hash/string_hash.h | 63 +-
be/src/gutil/int128.cc | 8 +-
be/src/gutil/int128.h | 389 +-
be/src/gutil/integral_types.h | 59 +-
be/src/gutil/linux_syscall_support.h | 3810 +++++++-------
be/src/gutil/logging-inl.h | 2 +-
be/src/gutil/macros.h | 68 +-
be/src/gutil/map-util.h | 778 ++-
be/src/gutil/move.h | 30 +-
be/src/gutil/once.cc | 74 +-
be/src/gutil/once.h | 94 +-
be/src/gutil/port.h | 619 ++-
be/src/gutil/ref_counted.cc | 69 +-
be/src/gutil/ref_counted.h | 359 +-
be/src/gutil/spinlock_internal.cc | 101 +-
be/src/gutil/spinlock_internal.h | 15 +-
be/src/gutil/spinlock_linux-inl.h | 75 +-
be/src/gutil/spinlock_posix-inl.h | 31 +-
be/src/gutil/spinlock_win32-inl.h | 18 +-
be/src/gutil/stl_util.h | 903 ++--
be/src/gutil/stringprintf.cc | 186 +-
be/src/gutil/stringprintf.h | 13 +-
be/src/gutil/strings/ascii_ctype.cc | 116 +-
be/src/gutil/strings/ascii_ctype.h | 50 +-
be/src/gutil/strings/charset.cc | 14 +-
be/src/gutil/strings/charset.h | 62 +-
be/src/gutil/strings/escaping.cc | 2768 +++++-----
be/src/gutil/strings/escaping.h | 150 +-
be/src/gutil/strings/fastmem.h | 190 +-
be/src/gutil/strings/join.cc | 216 +-
be/src/gutil/strings/join.h | 300 +-
be/src/gutil/strings/memutil.cc | 200 +-
be/src/gutil/strings/memutil.h | 119 +-
be/src/gutil/strings/numbers.cc | 1981 ++++---
be/src/gutil/strings/numbers.h | 178 +-
be/src/gutil/strings/split.cc | 1268 +++--
be/src/gutil/strings/split.h | 360 +-
be/src/gutil/strings/split_internal.h | 504 +-
be/src/gutil/strings/strcat.cc | 395 +-
be/src/gutil/strings/strcat.h | 434 +-
be/src/gutil/strings/stringpiece.cc | 232 +-
be/src/gutil/strings/stringpiece.h | 392 +-
be/src/gutil/strings/strip.cc | 439 +-
be/src/gutil/strings/strip.h | 70 +-
be/src/gutil/strings/substitute.cc | 188 +-
be/src/gutil/strings/substitute.h | 215 +-
be/src/gutil/strings/util.cc | 1607 +++---
be/src/gutil/strings/util.h | 212 +-
be/src/gutil/strtoint.cc | 64 +-
be/src/gutil/strtoint.h | 58 +-
be/src/gutil/sysinfo-test.cc | 82 +-
be/src/gutil/sysinfo.cc | 639 ++-
be/src/gutil/sysinfo.h | 8 +-
be/src/gutil/template_util.h | 90 +-
be/src/gutil/threading/thread_collision_warner.cc | 69 +-
be/src/gutil/threading/thread_collision_warner.h | 199 +-
be/src/gutil/type_traits.h | 427 +-
be/src/gutil/utf/utf.h | 50 +-
be/src/gutil/utf/utfdef.h | 10 +-
be/src/gutil/valgrind.h | 5468 ++++++++++----------
be/src/gutil/walltime.h | 165 +-
be/src/http/action/checksum_action.cpp | 40 +-
be/src/http/action/checksum_action.h | 12 +-
be/src/http/action/compaction_action.cpp | 65 +-
be/src/http/action/compaction_action.h | 15 +-
be/src/http/action/health_action.cpp | 9 +-
be/src/http/action/health_action.h | 9 +-
be/src/http/action/meta_action.cpp | 5 +-
be/src/http/action/meta_action.h | 12 +-
be/src/http/action/metrics_action.cpp | 7 +-
be/src/http/action/metrics_action.h | 9 +-
be/src/http/action/mini_load.cpp | 313 +-
be/src/http/action/mini_load.h | 46 +-
be/src/http/action/pprof_actions.cpp | 17 +-
be/src/http/action/pprof_actions.h | 2 +-
be/src/http/action/reload_tablet_action.cpp | 34 +-
be/src/http/action/reload_tablet_action.h | 15 +-
be/src/http/action/restore_tablet_action.h | 27 +-
be/src/http/action/snapshot_action.cpp | 30 +-
be/src/http/action/snapshot_action.h | 9 +-
be/src/http/action/stream_load.cpp | 88 +-
be/src/http/action/stream_load.h | 4 +-
be/src/http/action/tablets_info_action.cpp | 7 +-
be/src/http/action/tablets_info_action.h | 6 +-
be/src/http/action/update_config_action.cpp | 18 +-
be/src/http/default_path_handlers.cpp | 120 +-
be/src/http/default_path_handlers.h | 1 +
be/src/http/download_action.cpp | 29 +-
be/src/http/download_action.h | 15 +-
be/src/http/ev_http_server.cpp | 86 +-
be/src/http/ev_http_server.h | 13 +-
be/src/http/http_channel.cpp | 28 +-
be/src/http/http_channel.h | 7 +-
be/src/http/http_client.cpp | 39 +-
be/src/http/http_client.h | 22 +-
be/src/http/http_common.h | 6 +-
be/src/http/http_handler.h | 10 +-
be/src/http/http_headers.cpp | 2 +-
be/src/http/http_headers.h | 2 +-
be/src/http/http_method.cpp | 24 +-
be/src/http/http_method.h | 16 +-
be/src/http/http_parser.cpp | 21 +-
be/src/http/http_parser.h | 22 +-
be/src/http/http_request.cpp | 39 +-
be/src/http/http_request.h | 39 +-
be/src/http/http_response.cpp | 27 +-
be/src/http/http_response.h | 18 +-
be/src/http/http_status.cpp | 83 +-
be/src/http/http_status.h | 2 +-
be/src/http/monitor_action.cpp | 19 +-
be/src/http/monitor_action.h | 12 +-
be/src/http/rest_monitor_iface.h | 4 +-
be/src/http/utils.cpp | 13 +-
be/src/http/utils.h | 6 +-
be/src/http/web_page_handler.cpp | 15 +-
be/src/http/web_page_handler.h | 19 +-
be/src/olap/CMakeLists.txt | 1 +
be/src/olap/aggregate_func.cpp | 17 +-
be/src/olap/aggregate_func.h | 138 +-
be/src/olap/base_compaction.cpp | 46 +-
be/src/olap/base_compaction.h | 15 +-
be/src/olap/base_tablet.cpp | 5 +-
be/src/olap/base_tablet.h | 1 +
be/src/olap/bhp_lib.h | 1261 +++--
be/src/olap/bloom_filter_reader.cpp | 15 +-
be/src/olap/bloom_filter_reader.h | 8 +-
be/src/olap/bloom_filter_writer.cpp | 8 +-
be/src/olap/byte_buffer.cpp | 44 +-
be/src/olap/byte_buffer.h | 52 +-
be/src/olap/collect_iterator.cpp | 327 ++
be/src/olap/collect_iterator.h | 171 +
be/src/olap/collection.h | 19 +-
be/src/olap/column_block.h | 23 +-
be/src/olap/column_mapping.h | 2 +-
be/src/olap/column_predicate.h | 9 +-
be/src/olap/column_vector.cpp | 194 +-
be/src/olap/column_vector.h | 73 +-
be/src/olap/compaction.cpp | 107 +-
be/src/olap/compaction.h | 25 +-
be/src/olap/compaction_permit_limiter.cpp | 4 +
be/src/olap/compaction_permit_limiter.h | 1 +
be/src/olap/comparison_predicate.cpp | 444 +-
be/src/olap/comparison_predicate.h | 26 +-
be/src/olap/compress.cpp | 38 +-
be/src/olap/compress.h | 6 +-
be/src/olap/cumulative_compaction.cpp | 46 +-
be/src/olap/cumulative_compaction.h | 18 +-
be/src/olap/cumulative_compaction_policy.cpp | 128 +-
be/src/olap/cumulative_compaction_policy.h | 73 +-
be/src/olap/data_dir.cpp | 137 +-
be/src/olap/data_dir.h | 4 +-
be/src/olap/decimal12.h | 42 +-
be/src/olap/delete_handler.cpp | 65 +-
be/src/olap/delete_handler.h | 30 +-
be/src/olap/delta_writer.cpp | 25 +-
be/src/olap/delta_writer.h | 10 +-
be/src/olap/field.h | 227 +-
be/src/olap/file_helper.cpp | 93 +-
be/src/olap/file_helper.h | 155 +-
be/src/olap/file_stream.cpp | 70 +-
be/src/olap/file_stream.h | 80 +-
be/src/olap/fs/block_id.cpp | 4 +-
be/src/olap/fs/block_id.h | 37 +-
be/src/olap/fs/block_manager.h | 7 +-
be/src/olap/fs/block_manager_metrics.h | 1 -
be/src/olap/fs/file_block_manager.cpp | 119 +-
be/src/olap/fs/file_block_manager.h | 1 -
be/src/olap/fs/fs_util.cpp | 2 +-
be/src/olap/generic_iterators.cpp | 42 +-
be/src/olap/generic_iterators.h | 2 +-
be/src/olap/hll.cpp | 176 +-
be/src/olap/hll.h | 89 +-
be/src/olap/in_list_predicate.cpp | 332 +-
be/src/olap/in_list_predicate.h | 32 +-
be/src/olap/in_stream.cpp | 66 +-
be/src/olap/in_stream.h | 28 +-
be/src/olap/iterators.h | 30 +-
be/src/olap/key_coder.cpp | 9 +-
be/src/olap/key_coder.h | 104 +-
be/src/olap/lru_cache.cpp | 77 +-
be/src/olap/lru_cache.h | 728 ++-
be/src/olap/memory/column.cpp | 8 +-
be/src/olap/memtable.cpp | 14 +-
be/src/olap/memtable.h | 5 +-
be/src/olap/memtable_flush_executor.h | 11 +-
be/src/olap/merger.cpp | 31 +-
be/src/olap/merger.h | 10 +-
be/src/olap/null_predicate.cpp | 12 +-
be/src/olap/null_predicate.h | 5 +-
be/src/olap/olap_common.h | 112 +-
be/src/olap/olap_cond.cpp | 73 +-
be/src/olap/olap_cond.h | 64 +-
be/src/olap/olap_define.h | 100 +-
be/src/olap/olap_index.cpp | 64 +-
be/src/olap/olap_index.h | 134 +-
be/src/olap/olap_meta.cpp | 24 +-
be/src/olap/olap_meta.h | 8 +-
be/src/olap/olap_server.cpp | 163 +-
be/src/olap/olap_snapshot_converter.cpp | 89 +-
be/src/olap/olap_snapshot_converter.h | 35 +-
be/src/olap/options.cpp | 15 +-
be/src/olap/options.h | 13 +-
be/src/olap/out_stream.h | 64 +-
be/src/olap/page_cache.cpp | 12 +-
be/src/olap/page_cache.h | 14 +-
be/src/olap/push_handler.cpp | 1005 ++--
be/src/olap/push_handler.h | 113 +-
be/src/olap/reader.cpp | 752 +--
be/src/olap/reader.h | 89 +-
be/src/olap/row.h | 67 +-
be/src/olap/row_block.cpp | 19 +-
be/src/olap/row_block.h | 24 +-
be/src/olap/row_block2.cpp | 19 +-
be/src/olap/row_block2.h | 33 +-
be/src/olap/row_cursor.cpp | 52 +-
be/src/olap/row_cursor.h | 61 +-
be/src/olap/row_cursor_cell.h | 7 +-
be/src/olap/rowset/alpha_rowset.cpp | 124 +-
be/src/olap/rowset/alpha_rowset.h | 6 +-
be/src/olap/rowset/alpha_rowset_meta.cpp | 2 +-
be/src/olap/rowset/alpha_rowset_meta.h | 9 +-
be/src/olap/rowset/alpha_rowset_reader.cpp | 53 +-
be/src/olap/rowset/alpha_rowset_reader.h | 18 +-
be/src/olap/rowset/alpha_rowset_writer.cpp | 94 +-
be/src/olap/rowset/alpha_rowset_writer.h | 28 +-
be/src/olap/rowset/beta_rowset.cpp | 32 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 15 +-
be/src/olap/rowset/beta_rowset_reader.h | 4 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 53 +-
be/src/olap/rowset/beta_rowset_writer.h | 17 +-
be/src/olap/rowset/bit_field_reader.cpp | 13 +-
be/src/olap/rowset/bit_field_reader.h | 4 +-
be/src/olap/rowset/bit_field_writer.cpp | 15 +-
be/src/olap/rowset/bit_field_writer.h | 5 +-
be/src/olap/rowset/column_data.cpp | 122 +-
be/src/olap/rowset/column_data.h | 86 +-
be/src/olap/rowset/column_data_writer.cpp | 80 +-
be/src/olap/rowset/column_data_writer.h | 22 +-
be/src/olap/rowset/column_reader.cpp | 394 +-
be/src/olap/rowset/column_reader.h | 559 +-
be/src/olap/rowset/column_writer.cpp | 311 +-
be/src/olap/rowset/column_writer.h | 192 +-
be/src/olap/rowset/rowset.cpp | 14 +-
be/src/olap/rowset/rowset.h | 91 +-
be/src/olap/rowset/rowset_converter.cpp | 7 +-
be/src/olap/rowset/rowset_converter.h | 15 +-
be/src/olap/rowset/rowset_factory.cpp | 14 +-
be/src/olap/rowset/rowset_factory.h | 7 +-
be/src/olap/rowset/rowset_id_generator.h | 4 +-
be/src/olap/rowset/rowset_meta.h | 168 +-
be/src/olap/rowset/rowset_meta_manager.cpp | 58 +-
be/src/olap/rowset/rowset_meta_manager.h | 17 +-
be/src/olap/rowset/rowset_reader.h | 8 +-
be/src/olap/rowset/rowset_reader_context.h | 2 +-
be/src/olap/rowset/rowset_writer.h | 8 +-
be/src/olap/rowset/rowset_writer_context.h | 26 +-
be/src/olap/rowset/run_length_byte_reader.cpp | 11 +-
be/src/olap/rowset/run_length_byte_reader.h | 4 +-
be/src/olap/rowset/run_length_byte_writer.cpp | 9 +-
be/src/olap/rowset/run_length_byte_writer.h | 5 +-
be/src/olap/rowset/run_length_integer_reader.cpp | 10 +-
be/src/olap/rowset/run_length_integer_reader.h | 8 +-
be/src/olap/rowset/run_length_integer_writer.cpp | 16 +-
be/src/olap/rowset/run_length_integer_writer.h | 52 +-
be/src/olap/rowset/segment_group.cpp | 360 +-
be/src/olap/rowset/segment_group.h | 140 +-
be/src/olap/rowset/segment_reader.cpp | 194 +-
be/src/olap/rowset/segment_reader.h | 117 +-
be/src/olap/rowset/segment_v2/binary_dict_page.cpp | 66 +-
be/src/olap/rowset/segment_v2/binary_dict_page.h | 28 +-
be/src/olap/rowset/segment_v2/binary_plain_page.h | 61 +-
.../olap/rowset/segment_v2/binary_prefix_page.cpp | 28 +-
be/src/olap/rowset/segment_v2/binary_prefix_page.h | 36 +-
.../olap/rowset/segment_v2/bitmap_index_reader.cpp | 3 +-
.../olap/rowset/segment_v2/bitmap_index_reader.h | 24 +-
.../olap/rowset/segment_v2/bitmap_index_writer.cpp | 89 +-
.../olap/rowset/segment_v2/bitmap_index_writer.h | 3 +-
be/src/olap/rowset/segment_v2/bitshuffle_page.cpp | 27 +-
be/src/olap/rowset/segment_v2/bitshuffle_page.h | 136 +-
.../olap/rowset/segment_v2/bitshuffle_wrapper.cpp | 9 +-
.../rowset/segment_v2/block_split_bloom_filter.cpp | 3 +-
.../rowset/segment_v2/block_split_bloom_filter.h | 2 +-
be/src/olap/rowset/segment_v2/bloom_filter.cpp | 7 +-
be/src/olap/rowset/segment_v2/bloom_filter.h | 26 +-
.../segment_v2/bloom_filter_index_reader.cpp | 11 +-
.../rowset/segment_v2/bloom_filter_index_reader.h | 28 +-
.../segment_v2/bloom_filter_index_writer.cpp | 86 +-
.../rowset/segment_v2/bloom_filter_index_writer.h | 7 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 198 +-
be/src/olap/rowset/segment_v2/column_reader.h | 74 +-
be/src/olap/rowset/segment_v2/column_writer.cpp | 150 +-
be/src/olap/rowset/segment_v2/column_writer.h | 48 +-
.../rowset/segment_v2/empty_segment_iterator.cpp | 2 +-
.../rowset/segment_v2/empty_segment_iterator.h | 2 +-
be/src/olap/rowset/segment_v2/encoding_info.cpp | 103 +-
be/src/olap/rowset/segment_v2/encoding_info.h | 16 +-
.../rowset/segment_v2/frame_of_reference_page.h | 52 +-
be/src/olap/rowset/segment_v2/index_page.cpp | 6 +-
be/src/olap/rowset/segment_v2/index_page.h | 21 +-
.../rowset/segment_v2/indexed_column_reader.cpp | 23 +-
.../olap/rowset/segment_v2/indexed_column_reader.h | 21 +-
.../rowset/segment_v2/indexed_column_writer.cpp | 25 +-
.../olap/rowset/segment_v2/indexed_column_writer.h | 5 +-
be/src/olap/rowset/segment_v2/options.h | 5 +-
.../olap/rowset/segment_v2/ordinal_page_index.cpp | 10 +-
be/src/olap/rowset/segment_v2/ordinal_page_index.h | 24 +-
be/src/olap/rowset/segment_v2/page_builder.h | 6 +-
be/src/olap/rowset/segment_v2/page_decoder.h | 8 +-
be/src/olap/rowset/segment_v2/page_handle.h | 18 +-
be/src/olap/rowset/segment_v2/page_io.cpp | 33 +-
be/src/olap/rowset/segment_v2/page_io.h | 29 +-
be/src/olap/rowset/segment_v2/page_pointer.h | 22 +-
be/src/olap/rowset/segment_v2/parsed_page.h | 27 +-
be/src/olap/rowset/segment_v2/plain_page.h | 68 +-
be/src/olap/rowset/segment_v2/rle_page.h | 120 +-
be/src/olap/rowset/segment_v2/row_ranges.h | 68 +-
be/src/olap/rowset/segment_v2/segment.cpp | 60 +-
be/src/olap/rowset/segment_v2/segment.h | 21 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 112 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 21 +-
be/src/olap/rowset/segment_v2/segment_writer.cpp | 32 +-
be/src/olap/rowset/segment_v2/segment_writer.h | 12 +-
be/src/olap/rowset/segment_v2/zone_map_index.cpp | 9 +-
be/src/olap/rowset/segment_v2/zone_map_index.h | 14 +-
be/src/olap/rowset/segment_writer.cpp | 103 +-
be/src/olap/rowset/segment_writer.h | 14 +-
be/src/olap/schema.cpp | 10 +-
be/src/olap/schema.h | 29 +-
be/src/olap/schema_change.cpp | 372 +-
be/src/olap/schema_change.h | 29 +-
be/src/olap/selection_vector.h | 25 +-
be/src/olap/serialize.cpp | 110 +-
be/src/olap/serialize.h | 56 +-
be/src/olap/short_key_index.cpp | 17 +-
be/src/olap/short_key_index.h | 34 +-
be/src/olap/skiplist.h | 127 +-
be/src/olap/snapshot_manager.cpp | 172 +-
be/src/olap/snapshot_manager.h | 71 +-
be/src/olap/storage_engine.cpp | 284 +-
be/src/olap/storage_engine.h | 74 +-
be/src/olap/stream_index_common.cpp | 16 +-
be/src/olap/stream_index_common.h | 33 +-
be/src/olap/stream_index_reader.cpp | 39 +-
be/src/olap/stream_index_reader.h | 24 +-
be/src/olap/stream_index_writer.cpp | 14 +-
be/src/olap/stream_index_writer.h | 3 +-
be/src/olap/stream_name.cpp | 17 +-
be/src/olap/stream_name.h | 17 +-
be/src/olap/tablet.cpp | 369 +-
be/src/olap/tablet.h | 63 +-
be/src/olap/tablet_manager.cpp | 314 +-
be/src/olap/tablet_manager.h | 47 +-
be/src/olap/tablet_meta.cpp | 175 +-
be/src/olap/tablet_meta.h | 22 +-
be/src/olap/tablet_meta_manager.cpp | 59 +-
be/src/olap/tablet_meta_manager.h | 31 +-
be/src/olap/tablet_schema.cpp | 212 +-
be/src/olap/tablet_schema.h | 13 +-
be/src/olap/tablet_sync_service.cpp | 48 +-
be/src/olap/tablet_sync_service.h | 36 +-
be/src/olap/task/engine_alter_tablet_task.cpp | 23 +-
be/src/olap/task/engine_alter_tablet_task.h | 6 +-
be/src/olap/task/engine_batch_load_task.cpp | 122 +-
be/src/olap/task/engine_batch_load_task.h | 17 +-
be/src/olap/task/engine_checksum_task.cpp | 37 +-
be/src/olap/task/engine_checksum_task.h | 11 +-
be/src/olap/task/engine_clone_task.cpp | 444 +-
be/src/olap/task/engine_clone_task.h | 62 +-
be/src/olap/task/engine_publish_version_task.cpp | 44 +-
be/src/olap/task/engine_publish_version_task.h | 3 +-
be/src/olap/task/engine_storage_migration_task.cpp | 60 +-
be/src/olap/task/engine_storage_migration_task.h | 7 +-
be/src/olap/tuple.h | 16 +-
be/src/olap/txn_manager.cpp | 240 +-
be/src/olap/txn_manager.h | 103 +-
be/src/olap/types.cpp | 72 +-
be/src/olap/types.h | 415 +-
be/src/olap/uint24.h | 32 +-
be/src/olap/utils.cpp | 1167 ++---
be/src/olap/utils.h | 139 +-
be/src/olap/version_graph.cpp | 98 +-
be/src/olap/version_graph.h | 55 +-
be/src/olap/wrapper_field.cpp | 29 +-
be/src/olap/wrapper_field.h | 32 +-
be/src/plugin/plugin.h | 32 +-
be/src/plugin/plugin_loader.cpp | 55 +-
be/src/plugin/plugin_loader.h | 55 +-
be/src/plugin/plugin_mgr.cpp | 57 +-
be/src/plugin/plugin_mgr.h | 31 +-
be/src/plugin/plugin_zip.cpp | 51 +-
be/src/plugin/plugin_zip.h | 4 +-
be/src/runtime/broker_mgr.cpp | 24 +-
be/src/runtime/broker_mgr.h | 7 +-
be/src/runtime/buffer_control_block.cpp | 26 +-
be/src/runtime/buffer_control_block.h | 32 +-
be/src/runtime/buffered_block_mgr2.cc | 311 +-
be/src/runtime/buffered_block_mgr2.h | 58 +-
be/src/runtime/buffered_tuple_stream2.cc | 151 +-
be/src/runtime/buffered_tuple_stream2.h | 36 +-
be/src/runtime/buffered_tuple_stream2.inline.h | 9 +-
be/src/runtime/buffered_tuple_stream2_ir.cc | 10 +-
be/src/runtime/buffered_tuple_stream3.cc | 1529 +++---
be/src/runtime/buffered_tuple_stream3.h | 985 ++--
be/src/runtime/buffered_tuple_stream3.inline.h | 37 +-
be/src/runtime/bufferpool/buffer_allocator.cc | 1131 ++--
be/src/runtime/bufferpool/buffer_allocator.h | 316 +-
be/src/runtime/bufferpool/buffer_pool.cc | 709 ++-
be/src/runtime/bufferpool/buffer_pool.h | 724 ++-
be/src/runtime/bufferpool/buffer_pool_counters.h | 20 +-
be/src/runtime/bufferpool/buffer_pool_internal.h | 513 +-
be/src/runtime/bufferpool/free_list.h | 109 +-
be/src/runtime/bufferpool/reservation_tracker.cc | 614 ++-
be/src/runtime/bufferpool/reservation_tracker.h | 407 +-
.../bufferpool/reservation_tracker_counters.h | 14 +-
be/src/runtime/bufferpool/reservation_util.cc | 15 +-
be/src/runtime/bufferpool/reservation_util.h | 80 +-
be/src/runtime/bufferpool/suballocator.cc | 370 +-
be/src/runtime/bufferpool/suballocator.h | 266 +-
be/src/runtime/bufferpool/system_allocator.cc | 206 +-
be/src/runtime/bufferpool/system_allocator.h | 29 +-
be/src/runtime/cache/cache_utils.h | 2 +-
be/src/runtime/cache/result_cache.cpp | 17 +-
be/src/runtime/cache/result_cache.h | 2 +-
be/src/runtime/cache/result_node.cpp | 31 +-
be/src/runtime/cache/result_node.h | 2 +-
be/src/runtime/client_cache.cpp | 58 +-
be/src/runtime/client_cache.h | 95 +-
be/src/runtime/data_spliter.cpp | 86 +-
be/src/runtime/data_spliter.h | 24 +-
be/src/runtime/data_stream_mgr.cpp | 67 +-
be/src/runtime/data_stream_mgr.h | 36 +-
be/src/runtime/data_stream_recvr.cc | 112 +-
be/src/runtime/data_stream_recvr.h | 15 +-
be/src/runtime/data_stream_sender.cpp | 221 +-
be/src/runtime/data_stream_sender.h | 35 +-
be/src/runtime/datetime_value.cpp | 211 +-
be/src/runtime/datetime_value.h | 214 +-
be/src/runtime/decimal_value.cpp | 158 +-
be/src/runtime/decimal_value.h | 186 +-
be/src/runtime/decimalv2_value.cpp | 165 +-
be/src/runtime/decimalv2_value.h | 224 +-
be/src/runtime/descriptor_helper.h | 20 +-
be/src/runtime/descriptors.cpp | 205 +-
be/src/runtime/descriptors.h | 242 +-
be/src/runtime/disk_io_mgr.cc | 167 +-
be/src/runtime/disk_io_mgr.h | 83 +-
be/src/runtime/disk_io_mgr_internal.h | 33 +-
be/src/runtime/disk_io_mgr_reader_context.cc | 92 +-
be/src/runtime/disk_io_mgr_scan_range.cc | 36 +-
be/src/runtime/dpp_sink.cpp | 247 +-
be/src/runtime/dpp_sink.h | 36 +-
be/src/runtime/dpp_sink_internal.cpp | 91 +-
be/src/runtime/dpp_sink_internal.h | 140 +-
be/src/runtime/dpp_writer.cpp | 50 +-
be/src/runtime/dpp_writer.h | 6 +-
be/src/runtime/etl_job_mgr.cpp | 78 +-
be/src/runtime/etl_job_mgr.h | 20 +-
be/src/runtime/exec_env.cpp | 3 +-
be/src/runtime/exec_env.h | 1 -
be/src/runtime/exec_env_init.cpp | 108 +-
be/src/runtime/export_sink.cpp | 228 +-
be/src/runtime/export_sink.h | 8 +-
be/src/runtime/export_task_mgr.cpp | 55 +-
be/src/runtime/export_task_mgr.h | 7 +-
be/src/runtime/external_scan_context_mgr.cpp | 33 +-
be/src/runtime/external_scan_context_mgr.h | 12 +-
be/src/runtime/file_result_writer.cpp | 236 +-
be/src/runtime/file_result_writer.h | 17 +-
be/src/runtime/fragment_mgr.cpp | 263 +-
be/src/runtime/fragment_mgr.h | 22 +-
be/src/runtime/heartbeat_flags.h | 12 +-
be/src/runtime/initial_reservations.cc | 89 +-
be/src/runtime/initial_reservations.h | 66 +-
be/src/runtime/large_int_value.cpp | 8 +-
be/src/runtime/large_int_value.h | 17 +-
be/src/runtime/load_channel.cpp | 28 +-
be/src/runtime/load_channel.h | 11 +-
be/src/runtime/load_channel_mgr.cpp | 61 +-
be/src/runtime/load_channel_mgr.h | 11 +-
be/src/runtime/load_path_mgr.cpp | 59 +-
be/src/runtime/load_path_mgr.h | 16 +-
be/src/runtime/mem_pool.cpp | 45 +-
be/src/runtime/mem_pool.h | 33 +-
be/src/runtime/mem_tracker.cpp | 730 ++-
be/src/runtime/mem_tracker.h | 939 ++--
be/src/runtime/memory/chunk.h | 2 +-
be/src/runtime/memory/chunk_allocator.cpp | 17 +-
be/src/runtime/memory/chunk_allocator.h | 11 +-
be/src/runtime/memory/system_allocator.cpp | 13 +-
be/src/runtime/memory/system_allocator.h | 6 +-
be/src/runtime/memory_scratch_sink.cpp | 24 +-
be/src/runtime/memory_scratch_sink.h | 14 +-
be/src/runtime/message_body_sink.cpp | 16 +-
be/src/runtime/message_body_sink.h | 18 +-
be/src/runtime/multi_precision.h | 3 +-
be/src/runtime/mysql_result_writer.cpp | 42 +-
be/src/runtime/mysql_result_writer.h | 8 +-
be/src/runtime/mysql_table_sink.cpp | 8 +-
be/src/runtime/mysql_table_sink.h | 9 +-
be/src/runtime/mysql_table_writer.cpp | 40 +-
be/src/runtime/mysql_table_writer.h | 14 +-
be/src/runtime/plan_fragment_executor.cpp | 145 +-
be/src/runtime/plan_fragment_executor.h | 70 +-
be/src/runtime/primitive_type.cpp | 18 +-
be/src/runtime/primitive_type.h | 46 +-
be/src/runtime/qsorter.cpp | 35 +-
be/src/runtime/qsorter.h | 16 +-
be/src/runtime/query_statistics.cpp | 2 +-
be/src/runtime/query_statistics.h | 29 +-
be/src/runtime/raw_value.cpp | 118 +-
be/src/runtime/raw_value.h | 73 +-
be/src/runtime/raw_value_ir.cpp | 18 +-
be/src/runtime/record_batch_queue.cpp | 2 +-
be/src/runtime/record_batch_queue.h | 3 +-
be/src/runtime/result_buffer_mgr.cpp | 36 +-
be/src/runtime/result_buffer_mgr.h | 14 +-
be/src/runtime/result_queue_mgr.cpp | 11 +-
be/src/runtime/result_queue_mgr.h | 11 +-
be/src/runtime/result_sink.cpp | 59 +-
be/src/runtime/result_sink.h | 12 +-
be/src/runtime/result_writer.h | 9 +-
be/src/runtime/routine_load/data_consumer.cpp | 126 +-
be/src/runtime/routine_load/data_consumer.h | 83 +-
.../runtime/routine_load/data_consumer_group.cpp | 109 +-
be/src/runtime/routine_load/data_consumer_group.h | 30 +-
be/src/runtime/routine_load/data_consumer_pool.cpp | 69 +-
be/src/runtime/routine_load/data_consumer_pool.h | 13 +-
be/src/runtime/routine_load/kafka_consumer_pipe.h | 18 +-
.../routine_load/routine_load_task_executor.cpp | 206 +-
.../routine_load/routine_load_task_executor.h | 3 +-
be/src/runtime/row_batch.cpp | 200 +-
be/src/runtime/row_batch.h | 146 +-
be/src/runtime/runtime_state.cpp | 222 +-
be/src/runtime/runtime_state.h | 317 +-
be/src/runtime/small_file_mgr.cpp | 51 +-
be/src/runtime/small_file_mgr.h | 19 +-
be/src/runtime/snapshot_loader.cpp | 378 +-
be/src/runtime/snapshot_loader.h | 110 +-
be/src/runtime/sorted_run_merger.cc | 47 +-
be/src/runtime/sorted_run_merger.h | 4 +-
be/src/runtime/sorter.h | 19 +-
be/src/runtime/spill_sorter.cc | 301 +-
be/src/runtime/spill_sorter.h | 12 +-
be/src/runtime/stream_load/load_stream_mgr.cpp | 2 +-
be/src/runtime/stream_load/load_stream_mgr.h | 7 +-
be/src/runtime/stream_load/stream_load_context.cpp | 28 +-
be/src/runtime/stream_load/stream_load_context.h | 32 +-
.../runtime/stream_load/stream_load_executor.cpp | 20 +-
be/src/runtime/stream_load/stream_load_executor.h | 5 +-
be/src/runtime/stream_load/stream_load_pipe.h | 53 +-
be/src/runtime/string_value.cpp | 6 +-
be/src/runtime/string_value.h | 53 +-
be/src/runtime/string_value_ir.cpp | 5 +-
be/src/runtime/tablets_channel.cpp | 41 +-
be/src/runtime/tablets_channel.h | 21 +-
be/src/runtime/test_env.cc | 18 +-
be/src/runtime/test_env.h | 21 +-
be/src/runtime/thread_resource_mgr.cpp | 15 +-
be/src/runtime/thread_resource_mgr.h | 37 +-
be/src/runtime/tmp_file_mgr.cc | 50 +-
be/src/runtime/tmp_file_mgr.h | 33 +-
be/src/runtime/tuple.cpp | 48 +-
be/src/runtime/tuple.h | 32 +-
be/src/runtime/tuple_row.cpp | 3 +-
be/src/runtime/tuple_row.h | 22 +-
be/src/runtime/types.cpp | 21 +-
be/src/runtime/types.h | 33 +-
be/src/runtime/user_function_cache.cpp | 69 +-
be/src/runtime/user_function_cache.h | 23 +-
be/src/runtime/vectorized_row_batch.cpp | 22 +-
be/src/runtime/vectorized_row_batch.h | 71 +-
be/src/service/backend_options.cpp | 11 +-
be/src/service/backend_options.h | 5 +-
be/src/service/backend_service.cpp | 154 +-
be/src/service/backend_service.h | 43 +-
be/src/service/brpc.h | 12 +-
be/src/service/brpc_service.cpp | 14 +-
be/src/service/brpc_service.h | 3 +-
be/src/service/doris_main.cpp | 5 +-
be/src/service/http_service.cpp | 66 +-
be/src/service/http_service.h | 2 +-
be/src/service/internal_service.cpp | 200 +-
be/src/service/internal_service.h | 70 +-
be/src/testutil/desc_tbl_builder.cc | 14 +-
be/src/testutil/desc_tbl_builder.h | 22 +-
be/src/testutil/function_utils.cpp | 19 +-
be/src/testutil/function_utils.h | 10 +-
be/src/tools/meta_tool.cpp | 84 +-
be/src/udf/uda_test_harness.h | 158 +-
be/src/udf/udf.cpp | 134 +-
be/src/udf/udf.h | 129 +-
be/src/udf/udf_debug.h | 10 +-
be/src/udf/udf_internal.h | 86 +-
be/src/udf/udf_ir.cpp | 2 +-
be/src/util/aes_util.cpp | 71 +-
be/src/util/aes_util.h | 24 +-
be/src/util/aligned_new.h | 40 +-
be/src/util/alignment.h | 3 +-
be/src/util/arrow/row_batch.cpp | 178 +-
be/src/util/arrow/row_batch.h | 32 +-
be/src/util/arrow/row_block.cpp | 71 +-
be/src/util/arrow/row_block.h | 22 +-
be/src/util/arrow/utils.cpp | 2 +-
be/src/util/arrow/utils.h | 6 +-
be/src/util/barrier.h | 9 +-
be/src/util/bfd_parser.cpp | 53 +-
be/src/util/bfd_parser.h | 16 +-
be/src/util/bit_stream_utils.h | 190 +-
be/src/util/bit_stream_utils.inline.h | 287 +-
be/src/util/bit_util.h | 340 +-
be/src/util/bitmap.cpp | 48 +-
be/src/util/bitmap.h | 156 +-
be/src/util/bitmap_value.h | 318 +-
be/src/util/block_compression.cpp | 144 +-
be/src/util/block_compression.h | 8 +-
be/src/util/broker_load_error_hub.cpp | 22 +-
be/src/util/broker_load_error_hub.h | 15 +-
be/src/util/brpc_stub_cache.cpp | 2 +-
be/src/util/brpc_stub_cache.h | 8 +-
be/src/util/byte_buffer.h | 9 +-
be/src/util/cgroup_util.cpp | 71 +-
be/src/util/cgroup_util.h | 6 +-
be/src/util/cidr.cpp | 13 +-
be/src/util/coding.cpp | 4 +-
be/src/util/coding.h | 25 +-
be/src/util/condition_variable.cpp | 12 +-
be/src/util/condition_variable.h | 3 +-
be/src/util/core_local.cpp | 13 +-
be/src/util/core_local.h | 21 +-
be/src/util/countdown_latch.h | 27 +-
be/src/util/cpu_info.cpp | 485 +-
be/src/util/cpu_info.h | 372 +-
be/src/util/crc32c.cpp | 451 +-
be/src/util/crc32c.h | 1 +
be/src/util/date_func.cpp | 26 +-
be/src/util/date_func.h | 4 +-
be/src/util/debug/leak_annotations.h | 73 +-
be/src/util/debug/leakcheck_disabler.h | 12 +-
be/src/util/debug_counters.h | 13 +-
be/src/util/debug_util.cpp | 40 +-
be/src/util/debug_util.h | 8 +-
be/src/util/defer_op.h | 12 +-
be/src/util/disk_info.cpp | 6 +-
be/src/util/disk_info.h | 10 +-
be/src/util/doris_metrics.cpp | 112 +-
be/src/util/doris_metrics.h | 34 +-
be/src/util/dummy_runtime_profile.h | 6 +-
be/src/util/dynamic_util.cpp | 5 +-
be/src/util/dynamic_util.h | 3 +-
be/src/util/easy_json.cc | 202 +-
be/src/util/easy_json.h | 280 +-
be/src/util/errno.cpp | 6 +-
be/src/util/errno.h | 4 +-
be/src/util/error_util.cc | 6 +-
be/src/util/error_util.h | 4 +-
be/src/util/faststring.cc | 71 +-
be/src/util/faststring.h | 393 +-
be/src/util/file_cache.cpp | 26 +-
be/src/util/file_cache.h | 9 +-
be/src/util/file_utils.cpp | 41 +-
be/src/util/file_utils.h | 36 +-
be/src/util/filesystem_util.cc | 35 +-
be/src/util/filesystem_util.h | 5 +-
be/src/util/frame_of_reference_coding.cpp | 77 +-
be/src/util/frame_of_reference_coding.h | 46 +-
be/src/util/hash_util_ir.cpp | 8 +-
be/src/util/internal_queue.h | 392 +-
be/src/util/json_util.cpp | 2 +-
be/src/util/json_util.h | 14 +-
be/src/util/load_error_hub.cpp | 22 +-
be/src/util/load_error_hub.h | 18 +-
be/src/util/logging.h | 3 +-
be/src/util/md5.cpp | 6 +-
be/src/util/md5.h | 11 +-
be/src/util/mem_info.cpp | 20 +-
be/src/util/mem_info.h | 4 +-
be/src/util/mem_range.h | 24 +-
be/src/util/metrics.cpp | 51 +-
be/src/util/metrics.h | 164 +-
be/src/util/minizip/ioapi.h | 181 +-
be/src/util/minizip/unzip.h | 220 +-
be/src/util/monotime.cpp | 56 +-
be/src/util/monotime.h | 36 +-
be/src/util/murmur_hash3.cpp | 665 ++-
be/src/util/murmur_hash3.h | 2 +-
be/src/util/mustache/mustache.cc | 640 +--
be/src/util/mustache/mustache.h | 7 +-
be/src/util/mutex.cpp | 103 +-
be/src/util/mutex.h | 25 +-
be/src/util/mysql_global.h | 47 +-
be/src/util/mysql_load_error_hub.cpp | 30 +-
be/src/util/mysql_load_error_hub.h | 31 +-
be/src/util/mysql_row_buffer.cpp | 13 +-
be/src/util/mysql_row_buffer.h | 25 +-
be/src/util/network_util.cpp | 25 +-
be/src/util/network_util.h | 6 +-
be/src/util/null_load_error_hub.cpp | 7 +-
be/src/util/null_load_error_hub.h | 6 +-
be/src/util/once.h | 11 +-
be/src/util/os_info.cpp | 72 +-
be/src/util/os_info.h | 48 +-
be/src/util/os_util.cpp | 9 +-
be/src/util/parse_util.cpp | 13 +-
be/src/util/parse_util.h | 4 +-
be/src/util/path_builder.cpp | 5 +-
be/src/util/path_builder.h | 3 +-
be/src/util/path_util.cpp | 20 +-
be/src/util/perf_counters.cpp | 37 +-
be/src/util/perf_counters.h | 6 +-
be/src/util/pprof_utils.cpp | 42 +-
be/src/util/pprof_utils.h | 15 +-
be/src/util/pretty_printer.h | 35 +-
be/src/util/progress_updater.cpp | 34 +-
be/src/util/progress_updater.h | 20 +-
be/src/util/radix_sort.h | 125 +-
be/src/util/random.h | 13 +-
be/src/util/ref_count_closure.h | 19 +-
be/src/util/rle_encoding.h | 736 ++-
be/src/util/runtime_profile.cpp | 3 +-
be/src/util/runtime_profile.h | 173 +-
be/src/util/scoped_cleanup.h | 11 +-
be/src/util/simdutf8check.h | 612 +--
be/src/util/slice.cpp | 8 +-
be/src/util/slice.h | 78 +-
be/src/util/spinlock.cc | 1 -
be/src/util/spinlock.h | 9 +-
be/src/util/stack_util.cpp | 4 +-
be/src/util/stack_util.h | 2 +-
be/src/util/static_asserts.cpp | 4 +-
be/src/util/streaming_sampler.h | 40 +-
be/src/util/string_parser.cpp | 4 +-
be/src/util/string_util.cpp | 2 +-
be/src/util/string_util.h | 18 +-
be/src/util/symbols_util.cpp | 24 +-
be/src/util/symbols_util.h | 9 +-
be/src/util/system_metrics.cpp | 142 +-
be/src/util/system_metrics.h | 27 +-
be/src/util/tdigest.h | 120 +-
be/src/util/template_util.h | 2 +-
be/src/util/thread.cpp | 13 +-
be/src/util/threadpool.cpp | 173 +-
be/src/util/threadpool.h | 22 +-
be/src/util/thrift_client.cpp | 9 +-
be/src/util/thrift_client.h | 85 +-
be/src/util/thrift_rpc_helper.cpp | 75 +-
be/src/util/thrift_rpc_helper.h | 23 +-
be/src/util/thrift_server.cpp | 129 +-
be/src/util/thrift_server.h | 21 +-
be/src/util/thrift_util.h | 35 +-
be/src/util/time.cpp | 127 +-
be/src/util/time.h | 62 +-
be/src/util/timezone_utils.cpp | 7 +-
be/src/util/timezone_utils.h | 5 +-
be/src/util/trace.cpp | 315 +-
be/src/util/trace.h | 332 +-
be/src/util/trace_metrics.cpp | 39 +-
be/src/util/trace_metrics.h | 66 +-
be/src/util/tuple_row_compare.cpp | 3 +-
be/src/util/tuple_row_compare.h | 67 +-
be/src/util/types.h | 9 +-
be/src/util/uid_util.cpp | 2 +-
be/src/util/uid_util.h | 69 +-
be/src/util/url_coding.cpp | 3 +-
be/src/util/url_coding.h | 10 +-
be/src/util/url_parser.cpp | 12 +-
be/src/util/url_parser.h | 24 +-
be/src/util/utf8_check.cpp | 118 +-
be/src/util/utf8_check.h | 4 +-
be/src/util/uuid_generator.h | 10 +-
be/src/util/zip_util.cpp | 30 +-
be/src/util/zip_util.h | 18 +-
be/src/util/zlib.cpp | 129 +-
be/src/util/zlib.h | 2 +-
be/test/agent/agent_server_test.cpp | 31 +-
be/test/agent/cgroups_mgr_test.cpp | 45 +-
be/test/agent/heartbeat_server_test.cpp | 22 +-
be/test/agent/mock_pusher.h | 6 +-
be/test/agent/mock_task_worker_pool.h | 6 +-
be/test/agent/mock_utils.h | 58 +-
be/test/agent/utils_test.cpp | 10 +-
be/test/common/config_test.cpp | 10 +-
be/test/common/resource_tls_test.cpp | 11 +-
be/test/common/status_test.cpp | 5 +-
be/test/env/env_posix_test.cpp | 17 +-
be/test/exec/broker_reader_test.cpp | 12 +-
be/test/exec/broker_scan_node_test.cpp | 27 +-
be/test/exec/broker_scanner_test.cpp | 24 +-
be/test/exec/buffered_reader_test.cpp | 11 +-
be/test/exec/csv_scan_bench_test.cpp | 19 +-
be/test/exec/csv_scan_node_test.cpp | 34 +-
be/test/exec/csv_scanner_test.cpp | 15 +-
be/test/exec/es_http_scan_node_test.cpp | 27 +-
be/test/exec/es_predicate_test.cpp | 13 +-
be/test/exec/es_query_builder_test.cpp | 169 +-
be/test/exec/es_scan_node_test.cpp | 30 +-
be/test/exec/es_scan_reader_test.cpp | 55 +-
be/test/exec/hash_table_test.cpp | 38 +-
be/test/exec/json_scanner_test.cpp | 64 +-
be/test/exec/json_scanner_test_with_jsonpath.cpp | 70 +-
be/test/exec/mysql_scan_node_test.cpp | 22 +-
be/test/exec/mysql_scanner_test.cpp | 14 +-
be/test/exec/new_olap_scan_node_test.cpp | 41 +-
be/test/exec/olap_common_test.cpp | 144 +-
be/test/exec/olap_scan_node_test.cpp | 34 +-
be/test/exec/olap_scanner_test.cpp | 13 +-
be/test/exec/orc_scanner_test.cpp | 269 +-
be/test/exec/parquet_scanner_test.cpp | 80 +-
be/test/exec/plain_text_line_reader_bzip_test.cpp | 19 +-
be/test/exec/plain_text_line_reader_gzip_test.cpp | 36 +-
.../exec/plain_text_line_reader_lz4frame_test.cpp | 31 +-
be/test/exec/plain_text_line_reader_lzop_test.cpp | 22 +-
.../plain_text_line_reader_uncompressed_test.cpp | 18 +-
be/test/exec/schema_scan_node_test.cpp | 28 +-
.../schema_scanner/schema_authors_scanner_test.cpp | 37 +-
.../schema_charsets_scanner_test.cpp | 35 +-
.../schema_collations_scanner_test.cpp | 35 +-
.../schema_scanner/schema_columns_scanner_test.cpp | 62 +-
.../schema_create_table_scanner_test.cpp | 60 +-
.../schema_scanner/schema_engines_scanner_test.cpp | 33 +-
.../schema_open_tables_scanner_test.cpp | 58 +-
.../schema_schemata_scanner_test.cpp | 46 +-
.../schema_table_names_scanner_test.cpp | 52 +-
.../schema_scanner/schema_tables_scanner_test.cpp | 58 +-
.../schema_variables_scanner_test.cpp | 33 +-
be/test/exec/schema_scanner_test.cpp | 31 +-
be/test/exec/set_executor_test.cpp | 14 +-
be/test/exec/tablet_info_test.cpp | 25 +-
be/test/exprs/binary_predicate_test.cpp | 52 +-
be/test/exprs/bitmap_function_test.cpp | 112 +-
be/test/exprs/encryption_functions_test.cpp | 19 +-
be/test/exprs/hll_function_test.cpp | 15 +-
be/test/exprs/hybrid_set_test.cpp | 16 +-
be/test/exprs/in_op_test.cpp | 34 +-
be/test/exprs/in_predicate_test.cpp | 14 +-
be/test/exprs/json_function_test.cpp | 137 +-
be/test/exprs/math_functions_test.cpp | 8 +-
be/test/exprs/percentile_approx_test.cpp | 23 +-
be/test/exprs/string_functions_test.cpp | 103 +-
be/test/exprs/timestamp_functions_test.cpp | 74 +-
be/test/geo/geo_functions_test.cpp | 33 +-
be/test/geo/geo_types_test.cpp | 11 +-
be/test/geo/wkt_parse_test.cpp | 8 +-
be/test/http/http_client_test.cpp | 14 +-
be/test/http/http_utils_test.cpp | 15 +-
be/test/http/message_body_sink_test.cpp | 15 +-
be/test/http/metrics_action_test.cpp | 38 +-
be/test/http/stream_load_test.cpp | 27 +-
be/test/olap/aggregate_func_test.cpp | 29 +-
be/test/olap/bit_field_test.cpp | 60 +-
be/test/olap/bloom_filter_index_test.cpp | 12 +-
be/test/olap/bloom_filter_test.cpp | 10 +-
be/test/olap/byte_buffer_test.cpp | 27 +-
be/test/olap/column_reader_test.cpp | 1069 ++--
be/test/olap/column_vector_test.cpp | 44 +-
be/test/olap/comparison_predicate_test.cpp | 376 +-
be/test/olap/cumulative_compaction_policy_test.cpp | 190 +-
be/test/olap/decimal12_test.cpp | 10 +-
be/test/olap/delete_handler_test.cpp | 198 +-
be/test/olap/delta_writer_test.cpp | 148 +-
be/test/olap/file_helper_test.cpp | 32 +-
be/test/olap/file_utils_test.cpp | 81 +-
be/test/olap/fs/file_block_manager_test.cpp | 17 +-
be/test/olap/generic_iterators_test.cpp | 17 +-
be/test/olap/hll_test.cpp | 4 +-
be/test/olap/in_list_predicate_test.cpp | 334 +-
be/test/olap/key_coder_test.cpp | 22 +-
be/test/olap/lru_cache_test.cpp | 61 +-
be/test/olap/memory/column_delta_test.cpp | 2 +-
be/test/olap/memory/column_test.cpp | 12 +-
be/test/olap/memory/mem_tablet_test.cpp | 6 +-
be/test/olap/memory/partial_row_batch_test.cpp | 2 +-
be/test/olap/memtable_flush_executor_test.cpp | 23 +-
be/test/olap/null_predicate_test.cpp | 172 +-
be/test/olap/olap_meta_test.cpp | 25 +-
be/test/olap/olap_snapshot_converter_test.cpp | 2 +-
be/test/olap/options_test.cpp | 12 +-
be/test/olap/page_cache_test.cpp | 8 +-
be/test/olap/push_handler_test.cpp | 36 +-
be/test/olap/row_block_test.cpp | 23 +-
be/test/olap/row_block_v2_test.cpp | 13 +-
be/test/olap/row_cursor_test.cpp | 9 +-
be/test/olap/rowset/alpha_rowset_test.cpp | 62 +-
be/test/olap/rowset/beta_rowset_test.cpp | 25 +-
be/test/olap/rowset/rowset_converter_test.cpp | 71 +-
be/test/olap/rowset/rowset_meta_manager_test.cpp | 27 +-
be/test/olap/rowset/rowset_meta_test.cpp | 19 +-
.../rowset/segment_v2/binary_dict_page_test.cpp | 43 +-
.../rowset/segment_v2/binary_plain_page_test.cpp | 39 +-
.../rowset/segment_v2/binary_prefix_page_test.cpp | 26 +-
.../olap/rowset/segment_v2/bitmap_index_test.cpp | 34 +-
.../rowset/segment_v2/bitshuffle_page_test.cpp | 114 +-
.../rowset/segment_v2/block_bloom_filter_test.cpp | 8 +-
.../bloom_filter_index_reader_writer_test.cpp | 67 +-
.../rowset/segment_v2/bloom_filter_page_test.cpp | 49 +-
.../segment_v2/column_reader_writer_test.cpp | 158 +-
.../olap/rowset/segment_v2/encoding_info_test.cpp | 11 +-
.../segment_v2/frame_of_reference_page_test.cpp | 75 +-
.../rowset/segment_v2/ordinal_page_index_test.cpp | 11 +-
be/test/olap/rowset/segment_v2/plain_page_test.cpp | 157 +-
be/test/olap/rowset/segment_v2/rle_page_test.cpp | 52 +-
be/test/olap/rowset/segment_v2/row_ranges_test.cpp | 11 +-
be/test/olap/rowset/segment_v2/segment_test.cpp | 196 +-
.../olap/rowset/segment_v2/zone_map_index_test.cpp | 13 +-
.../rowset/unique_rowset_id_generator_test.cpp | 43 +-
be/test/olap/run_length_byte_test.cpp | 277 +-
be/test/olap/run_length_integer_test.cpp | 1106 +++-
be/test/olap/schema_change_test.cpp | 219 +-
be/test/olap/selection_vector_test.cpp | 11 +-
be/test/olap/serialize_test.cpp | 11 +-
be/test/olap/short_key_index_test.cpp | 15 +-
be/test/olap/skiplist_test.cpp | 86 +-
be/test/olap/storage_types_test.cpp | 32 +-
be/test/olap/stream_index_test.cpp | 104 +-
be/test/olap/tablet_meta_manager_test.cpp | 17 +-
be/test/olap/tablet_meta_test.cpp | 11 +-
be/test/olap/tablet_mgr_test.cpp | 43 +-
be/test/olap/tablet_schema_helper.h | 24 +-
be/test/olap/tablet_test.cpp | 24 +-
be/test/olap/timestamped_version_tracker_test.cpp | 89 +-
be/test/olap/txn_manager_test.cpp | 150 +-
be/test/plugin/example/plugin_example.cpp | 17 +-
be/test/plugin/plugin_loader_test.cpp | 41 +-
be/test/plugin/plugin_mgr_test.cpp | 33 +-
be/test/plugin/plugin_zip_test.cpp | 43 +-
be/test/runtime/buffer_control_block_test.cpp | 17 +-
be/test/runtime/buffered_block_mgr2_test.cpp | 137 +-
be/test/runtime/buffered_tuple_stream2_test.cpp | 160 +-
be/test/runtime/buffered_tuple_stream_test.cpp | 82 +-
be/test/runtime/cache/partition_cache_test.cpp | 54 +-
be/test/runtime/data_spliter_test.cpp | 25 +-
be/test/runtime/data_stream_test.cpp | 20 +-
be/test/runtime/datetime_value_test.cpp | 122 +-
be/test/runtime/decimal_value_test.cpp | 45 +-
be/test/runtime/decimalv2_value_test.cpp | 38 +-
be/test/runtime/disk_io_mgr_test.cpp | 230 +-
be/test/runtime/dpp_sink_internal_test.cpp | 19 +-
be/test/runtime/dpp_sink_test.cpp | 29 +-
be/test/runtime/etl_job_mgr_test.cpp | 24 +-
be/test/runtime/export_task_mgr_test.cpp | 24 +-
be/test/runtime/external_scan_context_mgr_test.cpp | 14 +-
be/test/runtime/fragment_mgr_test.cpp | 5 +-
be/test/runtime/free_list_test.cpp | 9 +-
be/test/runtime/heartbeat_flags_test.cpp | 8 +-
be/test/runtime/kafka_consumer_pipe_test.cpp | 27 +-
be/test/runtime/large_int_value_test.cpp | 14 +-
be/test/runtime/load_channel_mgr_test.cpp | 50 +-
be/test/runtime/mem_limit_test.cpp | 13 +-
be/test/runtime/mem_pool_test.cpp | 16 +-
be/test/runtime/memory/chunk_allocator_test.cpp | 2 +-
be/test/runtime/memory/system_allocator_test.cpp | 4 +-
be/test/runtime/memory_scratch_sink_test.cpp | 24 +-
be/test/runtime/qsorter_test.cpp | 37 +-
be/test/runtime/raw_value_test.cpp | 8 +-
be/test/runtime/result_buffer_mgr_test.cpp | 20 +-
be/test/runtime/result_queue_mgr_test.cpp | 18 +-
be/test/runtime/result_sink_test.cpp | 38 +-
.../runtime/routine_load_task_executor_test.cpp | 22 +-
be/test/runtime/small_file_mgr_test.cpp | 17 +-
be/test/runtime/snapshot_loader_test.cpp | 28 +-
be/test/runtime/sorter_test.cpp | 112 +-
be/test/runtime/string_buffer_test.cpp | 6 +-
be/test/runtime/string_value_test.cpp | 6 +-
.../test_data/user_function_cache/lib/my_add.cc | 6 +-
be/test/runtime/thread_resource_mgr_test.cpp | 26 +-
be/test/runtime/tmp_file_mgr_test.cpp | 46 +-
be/test/runtime/user_function_cache_test.cpp | 58 +-
be/test/udf/uda_test.cpp | 35 +-
be/test/udf/udf_test.cpp | 52 +-
be/test/util/aes_util_test.cpp | 31 +-
be/test/util/arrow/arrow_row_batch_test.cpp | 3 +-
be/test/util/arrow/arrow_row_block_test.cpp | 4 +-
be/test/util/arrow/arrow_work_flow_test.cpp | 11 +-
be/test/util/bit_stream_utils_test.cpp | 53 +-
be/test/util/bit_util_test.cpp | 13 +-
be/test/util/bitmap_test.cpp | 14 +-
be/test/util/bitmap_value_test.cpp | 29 +-
be/test/util/block_compression_test.cpp | 22 +-
be/test/util/blocking_queue_test.cpp | 18 +-
be/test/util/brpc_stub_cache_test.cpp | 7 +-
be/test/util/byte_buffer_test2.cpp | 9 +-
be/test/util/cgroup_util_test.cpp | 13 +-
be/test/util/cidr_test.cpp | 7 +-
be/test/util/coding_test.cpp | 10 +-
be/test/util/core_local_test.cpp | 10 +-
be/test/util/countdown_latch_test.cpp | 7 +-
be/test/util/counter_cond_variable_test.cpp | 9 +-
be/test/util/crc32c_test.cpp | 35 +-
be/test/util/decompress_test.cpp | 37 +-
be/test/util/doris_metrics_test.cpp | 46 +-
be/test/util/easy_json-test.cpp | 106 +-
be/test/util/faststring_test.cpp | 163 +-
be/test/util/file_cache_test.cpp | 4 +-
be/test/util/filesystem_util_test.cpp | 11 +-
be/test/util/frame_of_reference_coding_test.cpp | 6 +-
be/test/util/http_channel_test.cpp | 3 +-
be/test/util/internal_queue_test.cpp | 49 +-
be/test/util/json_util_test.cpp | 27 +-
be/test/util/lru_cache_util_test.cpp | 10 +-
be/test/util/md5_test.cpp | 6 +-
be/test/util/monotime_test.cpp | 11 +-
be/test/util/new_metrics_test.cpp | 70 +-
be/test/util/parse_util_test.cpp | 7 +-
be/test/util/path_trie_test.cpp | 8 +-
be/test/util/path_util_test.cpp | 6 +-
be/test/util/perf_counters_test.cpp | 24 +-
be/test/util/radix_sort_test.cpp | 15 +-
be/test/util/rle_encoding_test.cpp | 611 ++-
be/test/util/runtime_profile_test.cpp | 67 +-
be/test/util/scoped_cleanup_test.cpp | 5 +-
be/test/util/string_parser_test.cpp | 100 +-
be/test/util/string_util_test.cpp | 7 +-
be/test/util/tdigest_test.cpp | 16 +-
be/test/util/thread_pool_test.cpp | 10 +-
be/test/util/threadpool_test.cpp | 257 +-
be/test/util/trace_test.cpp | 131 +-
be/test/util/types_test.cpp | 9 +-
be/test/util/uid_util_test.cpp | 9 +-
be/test/util/url_coding_test.cpp | 29 +-
be/test/util/utf8_check_test.cpp | 124 +-
be/test/util/zip_util_test.cpp | 25 +-
.../check-format.sh | 20 +-
.../clang-format.sh | 19 +-
build-support/lintutils.py | 111 +
build-support/run_clang_format.py | 144 +
docs/en/administrator-guide/config/be_config.md | 14 +
docs/en/developer-guide/format-code.md | 27 +-
.../sql-statements/Data Definition/ALTER TABLE.md | 6 +-
docs/zh-CN/administrator-guide/config/be_config.md | 14 +
docs/zh-CN/developer-guide/format-code.md | 24 +-
.../sql-statements/Data Definition/ALTER TABLE.md | 6 +-
.../main/java/org/apache/doris/alter/Alter.java | 75 +-
.../doris/alter/MaterializedViewHandler.java | 59 +-
.../apache/doris/alter/SchemaChangeHandler.java | 225 +-
.../org/apache/doris/alter/SchemaChangeJob.java | 2 +-
.../java/org/apache/doris/backup/RestoreJob.java | 7 +-
.../java/org/apache/doris/catalog/Catalog.java | 176 +-
.../java/org/apache/doris/catalog/ColumnType.java | 15 +
.../java/org/apache/doris/catalog/Database.java | 20 +-
.../apache/doris/clone/ColocateTableBalancer.java | 53 +-
.../doris/common/proc/FrontendsProcNode.java | 4 +-
.../external/elasticsearch/EsShardPartitions.java | 14 +-
.../doris/http/rest/BootstrapFinishAction.java | 12 +
.../doris/httpv2/entity/ResponseEntityBuilder.java | 4 +
.../apache/doris/httpv2/rest/GetDdlStmtAction.java | 14 +-
.../doris/httpv2/rest/GetSmallFileAction.java | 2 +-
.../apache/doris/httpv2/rest/MetaInfoAction.java | 27 +-
.../apache/doris/httpv2/rest/RowCountAction.java | 22 +-
.../org/apache/doris/httpv2/rest/ShowAction.java | 10 +-
.../doris/httpv2/rest/StorageTypeCheckAction.java | 20 +-
.../doris/httpv2/rest/TableQueryPlanAction.java | 20 +-
.../doris/httpv2/rest/TableRowCountAction.java | 22 +-
.../doris/httpv2/rest/TableSchemaAction.java | 21 +-
.../java/org/apache/doris/load/AsyncDeleteJob.java | 2 +-
.../src/main/java/org/apache/doris/load/Load.java | 57 +-
.../java/org/apache/doris/master/MasterImpl.java | 8 +-
.../org/apache/doris/master/ReportHandler.java | 16 -
.../java/org/apache/doris/qe/ConnectProcessor.java | 3 +
.../main/java/org/apache/doris/qe/Coordinator.java | 11 +
.../java/org/apache/doris/qe/GlobalVariable.java | 3 +-
.../java/org/apache/doris/qe/MasterOpExecutor.java | 10 +
.../java/org/apache/doris/qe/StmtExecutor.java | 5 +
.../org/apache/doris/qe/cache/PartitionCache.java | 2 +-
.../java/org/apache/doris/system/Frontend.java | 6 +
.../apache/doris/system/FrontendHbResponse.java | 9 +-
.../java/org/apache/doris/system/HeartbeatMgr.java | 14 +-
.../org/apache/doris/system/SystemInfoService.java | 25 +-
.../apache/doris/task/HadoopLoadPendingTask.java | 44 +-
.../org/apache/doris/alter/RollupJobV2Test.java | 28 +-
.../apache/doris/alter/SchemaChangeJobV2Test.java | 70 +-
.../apache/doris/catalog/CreateFunctionTest.java | 2 +-
.../org/apache/doris/catalog/DatabaseTest.java | 43 +
.../doris/clone/ColocateTableBalancerTest.java | 71 +-
.../doris/cluster/SystemInfoServiceTest.java | 13 +-
.../java/org/apache/doris/qe/CoordinatorTest.java | 82 +
.../org/apache/doris/system/HeartbeatMgrTest.java | 26 +-
gensrc/script/gen_build_version.sh | 2 +
gensrc/thrift/FrontendService.thrift | 1 +
1403 files changed, 66418 insertions(+), 71559 deletions(-)
mode change 100755 => 100644 be/src/common/names.h
mode change 100755 => 100644 be/src/exec/intersect_node.cpp
mode change 100755 => 100644 be/src/exprs/agg_fn_evaluator.cpp
mode change 100755 => 100644 be/src/exprs/agg_fn_evaluator.h
mode change 100755 => 100644 be/src/exprs/anyval_util.cpp
mode change 100755 => 100644 be/src/exprs/anyval_util.h
mode change 100755 => 100644 be/src/exprs/udf_builtins.cpp
mode change 100755 => 100644 be/src/exprs/udf_builtins.h
create mode 100644 be/src/olap/collect_iterator.cpp
create mode 100644 be/src/olap/collect_iterator.h
mode change 100755 => 100644 be/src/olap/cumulative_compaction.cpp
mode change 100755 => 100644 be/src/olap/cumulative_compaction.h
mode change 100755 => 100644 be/src/olap/file_stream.cpp
mode change 100755 => 100644 be/src/olap/file_stream.h
mode change 100755 => 100644 be/src/olap/olap_meta.cpp
mode change 100755 => 100644 be/src/olap/olap_meta.h
mode change 100755 => 100644 be/src/olap/olap_snapshot_converter.cpp
mode change 100755 => 100644 be/src/olap/rowset/column_writer.cpp
mode change 100755 => 100644 be/src/olap/stream_index_common.cpp
mode change 100755 => 100644 be/src/olap/stream_index_common.h
mode change 100755 => 100644 be/src/olap/stream_index_reader.cpp
mode change 100755 => 100644 be/src/olap/stream_index_reader.h
mode change 100755 => 100644 be/src/olap/stream_index_writer.cpp
mode change 100755 => 100644 be/src/olap/stream_index_writer.h
mode change 100755 => 100644 be/src/olap/stream_name.cpp
mode change 100755 => 100644 be/src/olap/stream_name.h
mode change 100755 => 100644 be/src/olap/tablet_meta.cpp
mode change 100755 => 100644 be/src/olap/tablet_meta_manager.cpp
mode change 100755 => 100644 be/src/olap/txn_manager.cpp
mode change 100755 => 100644 be/src/olap/txn_manager.h
mode change 100755 => 100644 be/src/runtime/decimal_value.cpp
mode change 100755 => 100644 be/src/runtime/decimal_value.h
mode change 100755 => 100644 be/src/udf/uda_test_harness.h
mode change 100755 => 100644 be/src/udf/udf.cpp
mode change 100755 => 100644 be/src/udf/udf.h
mode change 100755 => 100644 be/src/udf/udf_debug.h
mode change 100755 => 100644 be/src/udf/udf_internal.h
mode change 100755 => 100644 be/src/util/aligned_new.h
mode change 100755 => 100644 be/src/util/condition_variable.h
mode change 100755 => 100644 be/src/util/cpu_info.cpp
mode change 100755 => 100644 be/src/util/cpu_info.h
mode change 100755 => 100644 be/src/util/dummy_runtime_profile.h
mode change 100755 => 100644 be/src/util/mem_range.h
mode change 100755 => 100644 be/src/util/os_info.cpp
mode change 100755 => 100644 be/src/util/os_info.h
mode change 100755 => 100644 be/src/util/radix_sort.h
mode change 100755 => 100644 be/src/util/time.cpp
mode change 100755 => 100644 be/src/util/time.h
mode change 100755 => 100644 be/test/olap/bit_field_test.cpp
mode change 100755 => 100644 be/test/olap/byte_buffer_test.cpp
mode change 100755 => 100644 be/test/olap/run_length_byte_test.cpp
mode change 100755 => 100644 be/test/olap/run_length_integer_test.cpp
mode change 100755 => 100644 be/test/olap/stream_index_test.cpp
mode change 100755 => 100644 be/test/olap/tablet_meta_manager_test.cpp
mode change 100755 => 100644 be/test/olap/tablet_meta_test.cpp
mode change 100755 => 100644 be/test/olap/tablet_test.cpp
mode change 100755 => 100644 be/test/plugin/example/plugin_example.cpp
mode change 100755 => 100644 be/test/plugin/plugin_zip_test.cpp
mode change 100755 => 100644 be/test/runtime/decimal_value_test.cpp
mode change 100755 => 100644 be/test/udf/uda_test.cpp
mode change 100755 => 100644 be/test/udf/udf_test.cpp
copy docs/build_help_zip.sh => build-support/check-format.sh (74%)
copy docs/build_help_zip.sh => build-support/clang-format.sh (74%)
create mode 100644 build-support/lintutils.py
create mode 100644 build-support/run_clang_format.py
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
