path	# lines of code
scala-client/src/main/scala/org/apache/pegasus/scalaclient/Models.scala	36
scala-client/src/main/scala/org/apache/pegasus/scalaclient/PegasusUtil.scala	104
scala-client/src/main/scala/org/apache/pegasus/scalaclient/ScalaPegasusTable.scala	233
scala-client/src/main/scala/org/apache/pegasus/scalaclient/ScalaPegasusClient.scala	201
scala-client/src/main/scala/org/apache/pegasus/scalaclient/Serializer.scala	60
scala-client/src/main/scala/org/apache/pegasus/scalaclient/ScalaPegasusClientFactory.scala	10
scala-client/src/main/scala/org/apache/pegasus/scalaclient/package.scala	33
scala-client/src/main/scala/org/apache/pegasus/scalaclient/ScalaPegasusAsyncTable.scala	149
scala-client/project/plugins.sbt	1
scala-client/build.sbt	25
build_tools/compile_thrift.py	151
build_tools/run-clang-format.py	313
build_tools/redis_proto_check.py	722
build_tools/collector_table_counter_gen.py	81
build_tools/check_license.py	128
build_tools/clang_tidy.py	99
pegic/shell/app.go	28
pegic/shell/convert.go	42
pegic/interactive/cmd/partition_index.go	29
pegic/interactive/cmd/encoding.go	78
pegic/interactive/cmd/init.go	46
pegic/interactive/cmd/scan.go	88
pegic/interactive/cmd/get.go	23
pegic/interactive/cmd/compression.go	52
pegic/interactive/cmd/use.go	38
pegic/interactive/cmd/set.go	25
pegic/interactive/cmd/del.go	24
pegic/interactive/run.go	23
pegic/main.go	20
pegic/executor/partition_index.go	36
pegic/executor/util/encoding.go	116
pegic/executor/util/asciihex.go	65
pegic/executor/util/compression.go	40
pegic/executor/util/javabytes.go	30
pegic/executor/scan.go	109
pegic/executor/get.go	34
pegic/executor/context.go	91
pegic/executor/set.go	20
pegic/executor/del.go	20
cmake_modules/FindJemalloc.cmake	74
cmake_modules/FindRT.cmake	79
cmake_modules/BaseFunctions.cmake	357
cmake_modules/CompilerInfo.cmake	44
cmake_modules/ThriftUtils.cmake	69
cmake_modules/FindDL.cmake	79
src/sample/main.cpp	71
src/nfs/nfs_client_impl.h	239
src/nfs/nfs.thrift	41
src/nfs/nfs_node_simple.h	35
src/nfs/nfs_node_simple.cpp	60
src/nfs/nfs_code_definition.h	11
src/nfs/nfs_server_impl.h	94
src/nfs/nfs_server_impl.cpp	209
src/nfs/nfs_node.h	81
src/nfs/nfs_client_impl.cpp	469
src/nfs/nfs_node.cpp	78
src/zookeeper/lock_struct.h	82
src/zookeeper/zookeeper_error.h	7
src/zookeeper/lock_types.h	17
src/zookeeper/zookeeper_session_mgr.cpp	29
src/zookeeper/zookeeper_session.h	145
src/zookeeper/zookeeper_error.cpp	23
src/zookeeper/lock_struct.cpp	688
src/zookeeper/distributed_lock_service_zookeeper.h	78
src/zookeeper/zookeeper_session.cpp	394
src/zookeeper/distributed_lock_service_zookeeper.cpp	230
src/zookeeper/zookeeper_session_mgr.h	17
src/include/rrdb/rrdb.client.h	376
src/include/rrdb/rrdb.code.definition.h	22
src/include/pegasus/error_def.h	41
src/include/pegasus/version.h	2
src/include/pegasus/error.h	6
src/include/pegasus/client.h	476
src/utils/config_api.cpp	59
src/utils/exp_delay.h	78
src/utils/safe_strerror_posix.cpp	66
src/utils/utils.h	50
src/utils/distributed_lock_service.h	66
src/utils/function_traits.h	80
src/utils/safe_strerror_posix.h	9
src/utils/chrono_literals.h	29
src/utils/env.cpp	153
src/utils/fmt_logging.h	297
src/utils/api_utilities.h	70
src/utils/extensible_object.h	158
src/utils/enum_helper.h	113
src/utils/singleton_store.h	84
src/utils/strings.h	66
src/utils/token_buckets.cpp	24
src/utils/strings.cpp	368
src/utils/string_conv.h	140
src/utils/metrics.h	1155
src/utils/gpid.cpp	16
src/utils/nth_element.h	61
src/utils/simple_logger.cpp	326
src/utils/thread_access_checker.cpp	18
src/utils/binary_reader.cpp	86
src/utils/logging_provider.h	44
src/utils/timer.h	152
src/utils/shared_io_service.cpp	42
src/utils/join_point.h	71
src/utils/crc.cpp	340
src/utils/throttling_controller.h	58
src/utils/endians.h	93
src/utils/rand.h	23
src/utils/token_bucket_throttling_controller.h	38
src/utils/customizable_id.h	151
src/utils/alloc.cpp	19
src/utils/crc.h	24
src/utils/filesystem.h	86
src/utils/error_code.cpp	34
src/utils/preloadable.h	17
src/utils/process_utils.cpp	74
src/utils/builtin_metrics.cpp	56
src/utils/long_adder.cpp	186
src/utils/math.h	22
src/utils/link.h	121
src/utils/bytes.h	9
src/utils/blob.h	213
src/utils/token_bucket_throttling_controller.cpp	122
src/utils/config_api.h	30
src/utils/binary_writer.cpp	146
src/utils/clock.h	18
src/utils/thread_access_checker.h	13
src/utils/load_dump_object.h	127
src/utils/synchronize.h	126
src/utils/fail_point_impl.h	73
src/utils/output_utils.cpp	153
src/utils/priority_queue.h	96
src/utils/factory_store.h	118
src/utils/latency_tracer.cpp	302
src/utils/flags.h	97
src/utils/process_utils.h	30
src/utils/token_buckets.h	19
src/utils/command_manager.cpp	190
src/utils/long_adder_bench/long_adder_bench.cpp	140
src/utils/je_ctl.h	26
src/utils/coredump.posix.cpp	37
src/utils/time_utils.cpp	33
src/utils/metrics.cpp	549
src/utils/fail_point.h	35
src/utils/lockp.std.h	59
src/utils/fail_point.cpp	125
src/utils/sys_exit_hook.h	19
src/utils/command_manager.h	142
src/utils/math.cpp	26
src/utils/alloc.h	57
src/utils/binary_writer.h	87
src/utils/zlocks.h	133
src/utils/latency_tracer.h	76
src/utils/TokenBucket.h	215
src/utils/work_queue.h	53
src/utils/config_helper.h	97
src/utils/threadpool_spec.h	89
src/utils/fmt_utils.h	9
src/utils/autoref_ptr.h	108
src/utils/configuration.cpp	334
src/utils/time_utils.h	97
src/utils/clock.cpp	12
src/utils/macros.h	3
src/utils/flags.cpp	331
src/utils/string_splitter.h	174
src/utils/output_utils.h	173
src/utils/builtin_metrics.h	21
src/utils/zlock_provider.h	129
src/utils/configuration.h	167
src/utils/fixed_size_buffer_pool.h	15
src/utils/coredump.h	12
src/utils/error_code.h	131
src/utils/uniq_timestamp_us.h	24
src/utils/rand.cpp	12
src/utils/throttling_controller.cpp	218
src/utils/threadpool_code.h	36
src/utils/env.h	27
src/utils/je_ctl.cpp	73
src/utils/filesystem.cpp	764
src/utils/logging.cpp	87
src/utils/hpc_locks/bitfield.h	116
src/utils/hpc_locks/sema.h	169
src/utils/hpc_locks/autoresetevent.h	48
src/utils/hpc_locks/rwlock.h	131
src/utils/hpc_locks/autoreseteventcondvar.h	38
src/utils/hpc_locks/benaphore.h	90
src/utils/optional.h	62
src/utils/singleton.h	17
src/utils/ports.h	67
src/utils/binary_reader.h	67
src/utils/long_adder.h	92
src/utils/shared_io_service.h	19
src/utils/casts.h	14
src/utils/errors.h	194
src/utils/simple_logger.h	67
src/utils/defer.h	24
src/runtime/api_layer1.h	23
src/runtime/service_engine.cpp	208
src/runtime/env.sim.h	14
src/runtime/simulator.cpp	83
src/runtime/scheduler.cpp	224
src/runtime/threadpool_code.cpp	21
src/runtime/providers.common.cpp	47
src/runtime/node_scoper.h	18
src/runtime/zlocks.cpp	173
src/runtime/message_utils.h	67
src/runtime/tracer.h	17
src/runtime/global_config.h	127
src/runtime/scheduler.h	104
src/runtime/sim_clock.h	14
src/runtime/profiler_header.h	45
src/runtime/env.sim.cpp	31
src/runtime/pipeline.h	154
src/runtime/serverlet.h	169
src/runtime/tool_api.h	134
src/runtime/build_config.h	116
src/runtime/service_app.h	61
src/runtime/core_main.cpp	16
src/runtime/profiler.cpp	395
src/runtime/env_provider.h	17
src/runtime/fault_injector.cpp	282
src/runtime/api_task.h	19
src/runtime/tool_api.cpp	127
src/runtime/nativerun.cpp	68
src/runtime/service_engine.h	74
src/runtime/service_api_c.cpp	462
src/runtime/tracer.cpp	331
src/runtime/providers.common.h	6
src/runtime/simulator.h	40
src/runtime/fault_injector.h	13
src/runtime/app_model.h	5
src/runtime/global_config.cpp	285
src/runtime/profiler.h	13
src/runtime/nativerun.h	14
src/perf_counter/perf_counter_utils.h	27
src/perf_counter/perf_counter.h	85
src/perf_counter/perf_counter_atomic.cpp	60
src/perf_counter/perf_counters.cpp	356
src/perf_counter/perf_counter_wrapper.h	49
src/perf_counter/perf_counters.h	69
src/perf_counter/perf_counter.cpp	33
src/perf_counter/perf_counter_atomic.h	356
src/tools/mutation_log_tool.cpp	103
src/tools/mutation_log_tool.h	21
src/common/fs_manager.cpp	489
src/common/bulk_load_common.cpp	9
src/common/replication.codes.h	178
src/common/gpid.h	57
src/common/replication_other_types.h	75
src/common/backup_common.cpp	96
src/common/json_helper.h	699
src/common/partition_split_common.h	13
src/common/common.h	7
src/common/common.cpp	24
src/common/serialization_helper/dsn_types.h	2
src/common/serialization_helper/thrift_helper.h	606
src/common/replication_common.cpp	267
src/common/replica_envs.h	52
src/common/fs_manager.h	127
src/common/replica_envs.cpp	65
src/common/duplication_common.h	44
src/common/duplication_internal.thrift	19
src/common/replication_common.h	52
src/common/replication_enums.h	138
src/common/duplication_common.cpp	188
src/common/consensus.thrift	142
src/common/manual_compact.h	11
src/common/backup_common.h	68
src/common/bulk_load_common.h	34
src/common/storage_serverlet.h	125
src/shell/argh.h	261
src/shell/command_helper.h	1918
src/shell/command_executor.h	32
src/shell/command_utils.h	76
src/shell/commands/bulk_load.cpp	420
src/shell/commands/global_properties.cpp	81
src/shell/commands/table_management.cpp	970
src/shell/commands/detect_hotkey.cpp	133
src/shell/commands/misc.cpp	21
src/shell/commands/debugger.cpp	293
src/shell/commands/rebalance.cpp	197
src/shell/commands/local_partition_split.cpp	555
src/shell/commands/recovery.cpp	346
src/shell/commands/cold_backup.cpp	432
src/shell/commands/data_operations.cpp	2657
src/shell/commands/node_management.cpp	738
src/shell/commands/duplication.cpp	547
src/shell/commands.h	146
src/shell/command_utils.cpp	62
src/shell/linenoise/linenoise.h	29
src/shell/linenoise/linenoise.c	790
src/shell/sds/sdsalloc.h	3
src/shell/sds/sds.h	220
src/shell/sds/sds.c	834
src/shell/command_output.h	22
src/shell/args.h	25
src/shell/main.cpp	822
src/redis_protocol/proxy_lib/redis_parser.h	198
src/redis_protocol/proxy_lib/proxy_layer.cpp	107
src/redis_protocol/proxy_lib/proxy_layer.h	79
src/redis_protocol/proxy_lib/redis_parser.cpp	1134
src/redis_protocol/proxy/main.cpp	69
src/security/sasl_wrapper.h	26
src/security/replica_access_controller.cpp	89
src/security/server_negotiation.cpp	144
src/security/sasl_server_wrapper.h	18
src/security/negotiation.h	38
src/security/negotiation_manager.h	38
src/security/client_negotiation.h	27
src/security/kms_client.cpp	156
src/security/kinit_context.h	10
src/security/replica_access_controller.h	34
src/security/access_controller.cpp	45
src/security/server_negotiation.h	25
src/security/sasl_server_wrapper.cpp	48
src/security/client_negotiation.cpp	165
src/security/negotiation_utils.h	36
src/security/negotiation_manager.cpp	116
src/security/kinit_context.cpp	251
src/security/sasl_client_wrapper.h	18
src/security/meta_access_controller.h	25
src/security/kms_client.h	29
src/security/init.cpp	65
src/security/access_controller.h	32
src/security/sasl_client_wrapper.cpp	49
src/security/meta_access_controller.cpp	94
src/security/init.h	8
src/security/negotiation.cpp	46
src/security/sasl_init.h	7
src/security/sasl_init.cpp	114
src/security/sasl_wrapper.cpp	72
src/block_service/local/local_service.h	79
src/block_service/local/local_service.cpp	460
src/block_service/block_service_manager.h	45
src/block_service/hdfs/hdfs_service.h	92
src/block_service/hdfs/hdfs_service.cpp	526
src/block_service/block_service.h	175
src/block_service/block_service_manager.cpp	149
src/client/partition_resolver_manager.cpp	52
src/client/partition_resolver_manager.h	22
src/client/partition_resolver_simple.h	81
src/client/replication_ddl_client.h	385
src/client/partition_resolver.cpp	93
src/client/partition_resolver_simple.cpp	359
src/client/partition_resolver.h	71
src/client/replication_ddl_client.cpp	1483
src/rpc/network.cpp	640
src/rpc/network.sim.h	66
src/rpc/request_meta.thrift	10
src/rpc/asio_rpc_session.cpp	167
src/rpc/dsn_message_parser.cpp	158
src/rpc/rpc_host_port.cpp	214
src/rpc/rpc_address.cpp	260
src/rpc/rpc_address.h	139
src/rpc/rpc_holder.h	269
src/rpc/thrift_message_parser.h	78
src/rpc/rpc_message.cpp	355
src/rpc/asio_rpc_session.h	36
src/rpc/asio_net_provider.cpp	385
src/rpc/rpc_message.h	149
src/rpc/rpc_engine.cpp	647
src/rpc/asio_net_provider.h	68
src/rpc/thrift_message_parser.cpp	296
src/rpc/rpc_stream.h	88
src/rpc/raw_message_parser.cpp	92
src/rpc/rpc_engine.h	130
src/rpc/rpc_task.cpp	102
src/rpc/network.sim.cpp	142
src/rpc/message_parser.h	63
src/rpc/serialization.h	69
src/rpc/raw_message_parser.h	22
src/rpc/dns_resolver.h	29
src/rpc/group_address.h	166
src/rpc/dns_resolver.cpp	126
src/rpc/rpc_host_port.h	293
src/rpc/dsn_message_parser.h	21
src/rpc/group_host_port.h	196
src/rpc/message_parser_manager.h	27
src/rpc/network.h	168
src/rpc/message_parser.cpp	139
src/failure_detector/fd.code.definition.h	27
src/failure_detector/fd.client.h	54
src/failure_detector/fd.thrift	27
src/failure_detector/failure_detector.cpp	444
src/failure_detector/failure_detector.h	130
src/failure_detector/failure_detector_multimaster.h	48
src/failure_detector/failure_detector_multimaster.cpp	92
src/failure_detector/fd.server.h	27
src/remote_cmd/remote_command.h	20
src/remote_cmd/remote_command.cpp	46
src/base/idl_utils.h	26
src/base/pegasus_value_schema.h	147
src/base/pegasus_rpc_types.h	25
src/base/meta_store.h	63
src/base/pegasus_utils.h	78
src/base/value_schema_v0.h	24
src/base/pegasus_key_schema.h	110
src/base/value_schema_v0.cpp	74
src/base/pegasus_utils.cpp	137
src/base/value_schema_v1.h	25
src/base/meta_store.cpp	149
src/base/value_schema_v2.h	25
src/base/value_schema_v1.cpp	88
src/base/value_schema_manager.h	22
src/base/value_schema_manager.cpp	49
src/base/value_schema_v2.cpp	94
src/base/value_field.h	35
src/task/task_tracker.h	100
src/task/timer_service.h	24
src/task/task_code.cpp	82
src/task/task_engine.sim.h	92
src/task/task_spec.h	244
src/task/hpc_task_queue.h	23
src/task/async_calls.h	174
src/task/task.cpp	368
src/task/task_worker.cpp	186
src/task/simple_task_queue.cpp	89
src/task/simple_task_queue.h	39
src/task/task_queue.h	55
src/task/task.h	337
src/task/task_worker.h	56
src/task/task_tracker.cpp	120
src/task/task_queue.cpp	93
src/task/hpc_task_queue.cpp	50
src/task/task_engine.h	68
src/task/task_engine.sim.cpp	177
src/task/task_code.h	113
src/task/task_engine.cpp	290
src/task/future_types.h	9
src/task/task_spec.cpp	196
src/server/compaction_operation.cpp	152
src/server/pegasus_write_service_impl.h	813
src/server/hotkey_collector.h	112
src/server/server_utils.cpp	55
src/server/info_collector.h	201
src/server/hotkey_collector.cpp	376
src/server/pegasus_write_service.cpp	432
src/server/result_writer.h	20
src/server/pegasus_read_service.h	80
src/server/pegasus_server_write.cpp	254
src/server/hotspot_partition_calculator.h	53
src/server/hotspot_partition_calculator.cpp	208
src/server/rocksdb_wrapper.h	69
src/server/logging_utils.h	5
src/server/pegasus_scan_context.h	100
src/server/pegasus_mutation_duplicator.cpp	230
src/server/server_utils.h	14
src/server/meta_server/main.cpp	24
src/server/key_ttl_compaction_filter.h	161
src/server/pegasus_server_write.h	70
src/server/hotspot_partition_stat.h	21
src/server/collector/main.cpp	23
src/server/pegasus_event_listener.cpp	77
src/server/replica_server/main.cpp	29
src/server/info_collector_app.h	22
src/server/pegasus_write_service.h	139
src/server/compaction_filter_rule.h	119
src/server/available_detector.cpp	451
src/server/capacity_unit_calculator.h	94
src/server/pegasus_server_impl_init.cpp	672
src/server/pegasus_server_impl.cpp	2957
src/server/range_read_limiter.h	71
src/server/compaction_filter_rule.cpp	69
src/server/pegasus_service_app.h	60
src/server/rocksdb_wrapper.cpp	222
src/server/info_collector_app.cpp	31
src/server/hashkey_transform.h	32
src/server/available_detector.h	75
src/server/pegasus_event_listener.h	28
src/server/pegasus_manual_compact_service.cpp	299
src/server/result_writer.cpp	66
src/server/info_collector.cpp	297
src/server/pegasus_mutation_duplicator.h	56
src/server/capacity_unit_calculator.cpp	344
src/server/pegasus_server_impl.h	379
src/server/hotkey_collector_state.h	19
src/server/pegasus_manual_compact_service.h	54
src/server/compaction_operation.h	125
src/server/main.cpp	30
src/http/service_version.h	10
src/http/config_http_service.cpp	42
src/http/http_call_registry.h	61
src/http/http_client.cpp	386
src/http/builtin_http_calls.cpp	78
src/http/http_server.h	97
src/http/http_client.h	183
src/http/http_server.cpp	233
src/http/http_status_code.cpp	21
src/http/http_message_parser.h	50
src/http/builtin_http_calls.h	11
src/http/http_method.h	21
src/http/pprof_http_service.h	61
src/http/uri_decoder.h	9
src/http/uri_decoder.cpp	58
src/http/http_status_code.h	25
src/http/pprof_http_service.cpp	442
src/http/service_version.cpp	4
src/http/http_server_impl.h	14
src/http/http_message_parser.cpp	187
src/replica/replication_app_base.h	164
src/replica/mutation.cpp	460
src/replica/mutation_log.h	192
src/replica/replica_http_service.h	69
src/replica/mutation_log.cpp	939
src/replica/replica_chkpt.cpp	404
src/replica/disk_cleaner.h	33
src/replica/replica_check.cpp	219
src/replica/log_block.h	70
src/replica/mutation.h	195
src/replica/replica.cpp	600
src/replica/kms_key_provider.cpp	16
src/replica/log_file.cpp	325
src/replica/replication_app_base.cpp	322
src/replica/replica_init.cpp	250
src/replica/log_file.h	112
src/replica/log_block.cpp	34
src/replica/mutation_cache.cpp	100
src/replica/replica_backup.cpp	604
src/replica/replication_service_app.h	31
src/replica/kms_key_provider.h	27
src/replica/replica_learn.cpp	1292
src/replica/prepare_list.cpp	134
src/replica/replica_base.h	37
src/replica/replica_stub.h	410
src/replica/log_file_stream.h	144
src/replica/mutation_log_utils.h	50
src/replica/replica_throttle.cpp	124
src/replica/replica_2pc.cpp	735
src/replica/mutation_log_replay.cpp	172
src/replica/replica_base.cpp	25
src/replica/replica_disk_migrator.h	40
src/replica/split/replica_split_manager.cpp	1322
src/replica/split/replica_split_manager.h	154
src/replica/bulk_load/replica_bulk_loader.cpp	958
src/replica/bulk_load/replica_bulk_loader.h	129
src/replica/disk_cleaner.cpp	206
src/replica/prepare_list.h	42
src/replica/replica_stub.cpp	2671
src/replica/replica_http_service.cpp	137
src/replica/replica_failover.cpp	81
src/replica/replica.h	499
src/replica/backup/replica_backup_server.cpp	78
src/replica/backup/replica_backup_manager.h	32
src/replica/backup/replica_backup_server.h	19
src/replica/backup/cold_backup_context.h	189
src/replica/backup/cold_backup_context.cpp	959
src/replica/backup/replica_backup_manager.cpp	191
src/replica/storage/simple_kv/simple_kv.server.impl.h	71
src/replica/storage/simple_kv/simple_kv.server.impl.cpp	247
src/replica/storage/simple_kv/simple_kv.server.h	71
src/replica/storage/simple_kv/simple_kv.main.cpp	22
src/replica/storage/simple_kv/simple_kv.app.example.h	71
src/replica/storage/simple_kv/simple_kv.code.definition.h	12
src/replica/storage/simple_kv/simple_kv.client.h	114
src/replica/storage/simple_kv/simple_kv.thrift	6
src/replica/replication_service_app.cpp	54
src/replica/replica_disk_migrator.cpp	259
src/replica/replica_restore.cpp	392
src/replica/replica_config.cpp	991
src/replica/mutation_cache.h	34
src/replica/replica_context.cpp	202
src/replica/mutation_log_utils.cpp	64
src/replica/replica_context.h	183
src/replica/duplication/replica_duplicator.h	114
src/replica/duplication/mutation_batch.cpp	132
src/replica/duplication/replica_duplicator.cpp	246
src/replica/duplication/mutation_duplicator.h	47
src/replica/duplication/load_from_private_log.h	65
src/replica/duplication/replica_follower.h	57
src/replica/duplication/mutation_batch.h	51
src/replica/duplication/duplication_sync_timer.cpp	160
src/replica/duplication/duplication_pipeline.h	50
src/replica/duplication/replica_duplicator_manager.h	65
src/replica/duplication/duplication_pipeline.cpp	90
src/replica/duplication/load_from_private_log.cpp	232
src/replica/duplication/replica_follower.cpp	219
src/replica/duplication/replica_duplicator_manager.cpp	178
src/replica/duplication/duplication_sync_timer.h	44
src/aio/aio_task.h	78
src/aio/aio_task.cpp	61
src/aio/disk_engine.cpp	206
src/aio/disk_engine.h	56
src/aio/aio_provider.h	51
src/aio/native_linux_aio_provider.cpp	128
src/aio/file_io.h	60
src/aio/aio_provider.cpp	18
src/aio/native_linux_aio_provider.h	30
src/aio/file_io.cpp	128
src/geo/lib/latlng_codec.cpp	94
src/geo/lib/geo_client.cpp	891
src/geo/lib/geo_client.h	250
src/geo/lib/latlng_codec.h	22
src/geo/bench/bench.cpp	121
src/ranger/ranger_resource_policy.h	145
src/ranger/ranger_resource_policy_manager.cpp	477
src/ranger/ranger_resource_policy.cpp	202
src/ranger/access_type.h	42
src/ranger/ranger_resource_policy_manager.h	75
src/meta/dump_file.h	121
src/meta/meta_service.h	372
src/meta/greedy_load_balancer.h	48
src/meta/meta_data.h	397
src/meta/meta_rpc_types.h	56
src/meta/meta_state_service_simple.h	218
src/meta/meta_options.cpp	47
src/meta/meta_service_app.cpp	70
src/meta/meta_options.h	23
src/meta/server_load_balancer.cpp	149
src/meta/meta_state_service_zookeeper.h	77
src/meta/meta_bulk_load_ingestion_context.cpp	163
src/meta/meta_state_service_zookeeper.cpp	353
src/meta/backup_engine.cpp	338
src/meta/meta_state_service_simple.cpp	465
src/meta/greedy_load_balancer.cpp	194
src/meta/distributed_lock_service_simple.h	67
src/meta/meta_service.cpp	1177
src/meta/table_metrics.cpp	294
src/meta/meta_split_service.h	51
src/meta/meta_split_service.cpp	525
src/meta/meta_state_service_utils.h	50
src/meta/meta_bulk_load_ingestion_context.h	63
src/meta/server_state_restore.cpp	218
src/meta/app_balance_policy.cpp	146
src/meta/meta_bulk_load_service.h	314
src/meta/app_balance_policy.h	48
src/meta/server_load_balancer.h	98
src/meta/partition_guardian.cpp	694
src/meta/app_env_validator.h	59
src/meta/cluster_balance_policy.cpp	468
src/meta/app_env_validator.cpp	321
src/meta/meta_server_failure_detector.cpp	274
src/meta/meta_state_service_utils.cpp	82
src/meta/load_balance_policy.h	244
src/meta/distributed_lock_service_simple.cpp	245
src/meta/meta_backup_service.cpp	1628
src/meta/server_state.cpp	3944
src/meta/cluster_balance_policy.h	157
src/meta/server_state.h	284
src/meta/meta_state_service_utils_impl.h	251
src/meta/meta_http_service.cpp	781
src/meta/meta_server_failure_detector.h	86
src/meta/meta_data.cpp	541
src/meta/partition_guardian.h	70
src/meta/meta_backup_service.h	304
src/meta/meta_bulk_load_service.cpp	1807
src/meta/meta_state_service.h	79
src/meta/load_balance_policy.cpp	690
src/meta/backup_engine.h	84
src/meta/meta_service_app.h	31
src/meta/meta_http_service.h	138
src/meta/table_metrics.h	178
src/meta/duplication/meta_duplication_service.cpp	776
src/meta/duplication/meta_duplication_service.h	110
src/meta/duplication/duplication_info.h	211
src/meta/duplication/duplication_info.cpp	225
src/gutil/no_destructor.h	32
src/gutil/map_util.h	390
src/gutil/map_traits.h	46
src/client_lib/mutation.cpp	62
src/client_lib/pegasus_client_impl.cpp	1206
src/client_lib/pegasus_client_factory_impl.h	23
src/client_lib/client_factory.cpp	12
src/client_lib/pegasus_scanner_impl.cpp	347
src/client_lib/pegasus_client_factory_impl.cpp	63
src/client_lib/pegasus_client_impl.h	292
idl/dsn.layer2.thrift	68
idl/dsn.thrift	22
idl/backup.thrift	157
idl/rrdb.thrift	274
idl/metadata.thrift	65
idl/meta_admin.thrift	361
idl/security.thrift	28
idl/partition_split.thrift	107
idl/bulk_load.thrift	150
idl/command.thrift	10
idl/utils.thrift	13
idl/replica_admin.thrift	100
idl/duplication.thrift	119
admin_tools/learn_stat.py	87
collector/metrics/metric_collector.go	449
collector/metrics/meta_server_metrics.go	4
collector/metrics/replica_server_metrics.go	4
collector/usage/usage_recorder.go	77
collector/hotspot/partition_detector.go	33
collector/templates/index.html	57
collector/aggregate/perf_client.go	179
collector/aggregate/hook.go	36
collector/aggregate/table_stats.go	90
collector/aggregate/history.go	73
collector/aggregate/perf_session.go	57
collector/aggregate/aggregator.go	116
collector/aggregate/aggregatable.go	67
collector/aggregate/perf_counter_decoder.go	36
collector/sink/falcon_sink.go	111
collector/sink/sink.go	27
collector/sink/prometheus_sink.go	74
collector/webui/tables.go	10
collector/webui/webserver.go	42
collector/webui/index.go	43
collector/main.go	84
collector/avail/detector.go	110
python-client/pypegasus/transport/__init__.py	1
python-client/pypegasus/transport/compat.py	13
python-client/pypegasus/transport/protocol.py	114
python-client/pypegasus/utils/tools.py	65
python-client/pypegasus/utils/__init__.py	1
python-client/pypegasus/__init__.py	1
python-client/pypegasus/pgclient.py	690
python-client/pypegasus/operate/__init__.py	1
python-client/pypegasus/operate/packet.py	197
python-client/pypegasus/base/ttypes.py	309
python-client/pypegasus/base/__init__.py	1
python-client/pypegasus/base/constants.py	5
python-client/__init__.py	1
python-client/sample.py	89
python-client/setup.py	26
admin-cli/shell/shell.go	19
admin-cli/shell/context.go	23
admin-cli/util/http_client.go	50
admin-cli/util/common_utils.go	46
admin-cli/util/perf_counter.go	44
admin-cli/util/pegasus_node.go	161
admin-cli/client/meta.go	525
admin-cli/client/replica_health.go	117
admin-cli/client/migrate_node.go	132
admin-cli/client/options.go	6
admin-cli/client/remote_command.go	67
admin-cli/tabular/template.go	161
admin-cli/tabular/printer.go	52
admin-cli/main.go	33
admin-cli/executor/manual_compaction.go	21
admin-cli/executor/table_stat.go	84
admin-cli/executor/drop_table.go	12
admin-cli/executor/recall_table.go	16
admin-cli/executor/server_config.go	133
admin-cli/executor/partition_split.go	129
admin-cli/executor/bulk_load.go	396
admin-cli/executor/backup_restore.go	95
admin-cli/executor/list_tables.go	74
admin-cli/executor/compaction.go	150
admin-cli/executor/list_nodes.go	118
admin-cli/executor/toolkits/nodesmigrator/action.go	60
admin-cli/executor/toolkits/nodesmigrator/migrator.go	286
admin-cli/executor/toolkits/nodesmigrator/nodes.go	79
admin-cli/executor/toolkits/nodesmigrator/manager.go	97
admin-cli/executor/toolkits/log.go	20
admin-cli/executor/toolkits/diskbalancer/migrator.go	212
admin-cli/executor/toolkits/diskbalancer/balancer.go	66
admin-cli/executor/toolkits/tablemigrator/switcher.go	96
admin-cli/executor/toolkits/tablemigrator/migrator.go	112
admin-cli/executor/toolkits/nodesbalancer/migrator.go	201
admin-cli/executor/toolkits/nodesbalancer/balancer.go	87
admin-cli/executor/create_table.go	48
admin-cli/executor/disk_migrate.go	34
admin-cli/executor/nodes_stat.go	73
admin-cli/executor/use_table.go	18
admin-cli/executor/table_partitions.go	74
admin-cli/executor/table_env.go	53
admin-cli/executor/duplication.go	31
admin-cli/executor/partition_stat.go	70
admin-cli/executor/client.go	55
admin-cli/executor/cluster_info.go	14
admin-cli/executor/table_version.go	59
admin-cli/executor/disk_info.go	183
admin-cli/executor/meta_level.go	31
admin-cli/executor/server_info.go	42
admin-cli/executor/remote_command.go	35
admin-cli/cmd/manual_compaction.go	54
admin-cli/cmd/table_stat.go	15
admin-cli/cmd/table_migrator.go	27
admin-cli/cmd/drop_table.go	38
admin-cli/cmd/nodes_migrator.go	35
admin-cli/cmd/recall_table.go	32
admin-cli/cmd/server_config.go	64
admin-cli/cmd/partition_split.go	103
admin-cli/cmd/bulk_load.go	125
admin-cli/cmd/disk_balance.go	40
admin-cli/cmd/backup_restore.go	98
admin-cli/cmd/list_tables.go	19
admin-cli/cmd/compaction.go	40
admin-cli/cmd/node_stat.go	17
admin-cli/cmd/list_nodes.go	15
admin-cli/cmd/create_table.go	33
admin-cli/cmd/init.go	11
admin-cli/cmd/use_table.go	51
admin-cli/cmd/table_env.go	85
admin-cli/cmd/duplication.go	78
admin-cli/cmd/partition_stat.go	15
admin-cli/cmd/nodes_balancer.go	21
admin-cli/cmd/cluster_info.go	15
admin-cli/cmd/table_version.go	15
admin-cli/cmd/disk_info.go	55
admin-cli/cmd/utils.go	11
admin-cli/cmd/table_partition.go	15
admin-cli/cmd/meta_level.go	50
admin-cli/cmd/server_info.go	15
admin-cli/cmd/remote_command.go	43
go-client/generator/main.go	159
go-client/idl/rrdb/rrdb-remote/rrdb-remote.go	523
go-client/idl/rrdb/rrdb-consts.go	19
go-client/idl/rrdb/meta-remote/meta-remote.go	170
go-client/idl/rrdb/GoUnusedProtection__.go	2
go-client/idl/replication/dsn.layer2-consts.go	17
go-client/idl/replication/dsn.layer2.go	1925
go-client/idl/replication/GoUnusedProtection__.go	2
go-client/idl/admin/bulk_load-consts.go	19
go-client/idl/admin/metadata.go	1218
go-client/idl/admin/backup.go	4764
go-client/idl/admin/partition_split.go	2883
go-client/idl/admin/bulk_load.go	4064
go-client/idl/admin/meta_admin-consts.go	19
go-client/idl/admin/duplication-consts.go	19
go-client/idl/admin/duplication.go	2333
go-client/idl/admin/backup-consts.go	19
go-client/idl/admin/metadata-consts.go	19
go-client/idl/admin/partition_split-consts.go	19
go-client/idl/admin/GoUnusedProtection__.go	2
go-client/idl/base/rocskdb_err_string.go	34
go-client/idl/base/error_code.go	153
go-client/idl/base/blob.go	28
go-client/idl/base/gpid.go	27
go-client/idl/base/rpc_address.go	44
go-client/idl/base/host_port.go	71
go-client/idl/base/GoUnusedProtection__.go	2
go-client/idl/radmin/replica_admin-consts.go	21
go-client/idl/radmin/replica_admin.go	3275
go-client/idl/radmin/GoUnusedProtection__.go	2
go-client/idl/cmd/command-consts.go	15
go-client/idl/cmd/GoUnusedProtection__.go	2
go-client/idl/cmd/command.go	467
go-client/admin/remote_cmd_client.go	37
go-client/admin/client.go	183
go-client/rpc/main/echo.go	38
go-client/rpc/stream_in.go	29
go-client/rpc/utils.go	19
go-client/rpc/codec.go	6
go-client/rpc/stream_out.go	23
go-client/rpc/rpc_conn.go	154
go-client/pegasus/util.go	37
go-client/pegasus/check_and_set.go	33
go-client/pegasus/filter.go	13
go-client/pegasus/scanner.go	256
go-client/pegasus/table_connector.go	674
go-client/pegasus/retry_failover.go	29
go-client/pegasus/config.go	4
go-client/pegasus/client.go	74
go-client/pegasus/error.go	59
go-client/pegasus/op/op.go	10
go-client/pegasus/op/multiget.go	57
go-client/pegasus/op/check_and_set.go	46
go-client/pegasus/op/ttl.go	32
go-client/pegasus/op/multiset.go	55
go-client/pegasus/op/get.go	32
go-client/pegasus/op/incr.go	32
go-client/pegasus/op/sortkey_count.go	24
go-client/pegasus/op/multidel.go	34
go-client/pegasus/op/utils.go	100
go-client/pegasus/op/set.go	44
go-client/pegasus/op/del.go	28
go-client/example/main.go	60
go-client/pegalog/logger.go	44
go-client/pegalog/logrus_logger.go	40
go-client/session/radmin_rpc_types.go	49
go-client/session/replica_session.go	172
go-client/session/session.go	287
go-client/session/addr.go	28
go-client/session/header.go	39
go-client/session/admin_rpc_types.go	579
go-client/session/meta_call.go	130
go-client/session/codec.go	409
go-client/session/meta_session.go	108
go-client/integration/failover-test/main.go	42
java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java	230
java-client/src/main/java/org/apache/pegasus/metrics/MetricsManager.java	54
java-client/src/main/java/org/apache/pegasus/metrics/MetricsPool.java	102
java-client/src/main/java/org/apache/pegasus/tools/WriteLimiter.java	150
java-client/src/main/java/org/apache/pegasus/tools/FlowController.java	59
java-client/src/main/java/org/apache/pegasus/tools/ZstdWrapper.java	55
java-client/src/main/java/org/apache/pegasus/tools/Tools.java	122
java-client/src/main/java/org/apache/pegasus/operator/rrdb_ttl_operator.java	37
java-client/src/main/java/org/apache/pegasus/operator/rrdb_check_and_set_operator.java	43
java-client/src/main/java/org/apache/pegasus/operator/rrdb_multi_remove_operator.java	39
java-client/src/main/java/org/apache/pegasus/operator/rrdb_scan_operator.java	38
java-client/src/main/java/org/apache/pegasus/operator/rrdb_put_operator.java	42
java-client/src/main/java/org/apache/pegasus/operator/rrdb_multi_get_operator.java	39
java-client/src/main/java/org/apache/pegasus/operator/rrdb_check_and_mutate_operator.java	43
java-client/src/main/java/org/apache/pegasus/operator/query_cfg_operator.java	39
java-client/src/main/java/org/apache/pegasus/operator/rrdb_get_operator.java	37
java-client/src/main/java/org/apache/pegasus/operator/rrdb_multi_put_operator.java	43
java-client/src/main/java/org/apache/pegasus/operator/rrdb_remove_operator.java	38
java-client/src/main/java/org/apache/pegasus/operator/rrdb_get_scanner_operator.java	40
java-client/src/main/java/org/apache/pegasus/operator/batch_get_operator.java	45
java-client/src/main/java/org/apache/pegasus/operator/drop_app_operator.java	43
java-client/src/main/java/org/apache/pegasus/operator/read_operator.java	11
java-client/src/main/java/org/apache/pegasus/operator/rrdb_sortkey_count_operator.java	39
java-client/src/main/java/org/apache/pegasus/operator/list_apps_operator.java	43
java-client/src/main/java/org/apache/pegasus/operator/create_app_operator.java	43
java-client/src/main/java/org/apache/pegasus/operator/negotiation_operator.java	39
java-client/src/main/java/org/apache/pegasus/operator/client_operator.java	75
java-client/src/main/java/org/apache/pegasus/operator/rrdb_clear_scanner_operator.java	30
java-client/src/main/java/org/apache/pegasus/operator/rrdb_incr_operator.java	38
java-client/src/main/java/org/apache/pegasus/security/Credential.java	18
java-client/src/main/java/org/apache/pegasus/security/AuthReplicaSessionInterceptor.java	23
java-client/src/main/java/org/apache/pegasus/security/KerberosProtocol.java	160
java-client/src/main/java/org/apache/pegasus/security/AuthProtocol.java	10
java-client/src/main/java/org/apache/pegasus/security/SaslWrapper.java	50
java-client/src/main/java/org/apache/pegasus/security/Negotiation.java	141
java-client/src/main/java/org/apache/pegasus/security/KerberosCredential.java	74
java-client/src/main/java/org/apache/pegasus/util/PropertyUtils.java	30
java-client/src/main/java/org/apache/pegasus/client/CheckType.java	28
java-client/src/main/java/org/apache/pegasus/client/retry/ExponentialBackoffRetryPolicy.java	37
java-client/src/main/java/org/apache/pegasus/client/retry/RetryPolicies.java	12
java-client/src/main/java/org/apache/pegasus/client/retry/DefaultRetryPolicy.java	21
java-client/src/main/java/org/apache/pegasus/client/retry/RetryPolicy.java	28
java-client/src/main/java/org/apache/pegasus/client/HashKeyData.java	32
java-client/src/main/java/org/apache/pegasus/client/PegasusAdminClientInterface.java	27
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java	2108
java-client/src/main/java/org/apache/pegasus/client/SetItem.java	22
java-client/src/main/java/org/apache/pegasus/client/FutureGroup.java	80
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java	378
java-client/src/main/java/org/apache/pegasus/client/PException.java	43
java-client/src/main/java/org/apache/pegasus/client/TableOptions.java	26
java-client/src/main/java/org/apache/pegasus/client/PegasusScannerInterface.java	11
java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java	364
java-client/src/main/java/org/apache/pegasus/client/MultiGetOptions.java	18
java-client/src/main/java/org/apache/pegasus/client/Mutations.java	44
java-client/src/main/java/org/apache/pegasus/client/ListAppInfoType.java	12
java-client/src/main/java/org/apache/pegasus/client/PegasusAdminClientFactory.java	14
java-client/src/main/java/org/apache/pegasus/client/PegasusClient.java	463
java-client/src/main/java/org/apache/pegasus/client/PConfigUtil.java	112
java-client/src/main/java/org/apache/pegasus/client/PegasusClientFactory.java	81
java-client/src/main/java/org/apache/pegasus/client/FilterType.java	14
java-client/src/main/java/org/apache/pegasus/client/DelRangeOptions.java	16
java-client/src/main/java/org/apache/pegasus/client/CheckAndMutateOptions.java	8
java-client/src/main/java/org/apache/pegasus/client/PegasusAbstractClient.java	43
java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java	327
java-client/src/main/java/org/apache/pegasus/client/PegasusAdminClient.java	202
java-client/src/main/java/org/apache/pegasus/client/CheckAndSetOptions.java	10
java-client/src/main/java/org/apache/pegasus/client/request/DeleteBatch.java	13
java-client/src/main/java/org/apache/pegasus/client/request/MultiGetBatch.java	14
java-client/src/main/java/org/apache/pegasus/client/request/BatchWithResponse.java	20
java-client/src/main/java/org/apache/pegasus/client/request/Batch.java	28
java-client/src/main/java/org/apache/pegasus/client/request/MultiDelete.java	26
java-client/src/main/java/org/apache/pegasus/client/request/MultiGet.java	26
java-client/src/main/java/org/apache/pegasus/client/request/AbstractBatch.java	24
java-client/src/main/java/org/apache/pegasus/client/request/Get.java	11
java-client/src/main/java/org/apache/pegasus/client/request/Delete.java	11
java-client/src/main/java/org/apache/pegasus/client/request/GetBatch.java	13
java-client/src/main/java/org/apache/pegasus/client/request/SetBatch.java	13
java-client/src/main/java/org/apache/pegasus/client/request/MultiDeleteBatch.java	13
java-client/src/main/java/org/apache/pegasus/client/request/Set.java	21
java-client/src/main/java/org/apache/pegasus/client/request/MultiSet.java	34
java-client/src/main/java/org/apache/pegasus/client/request/MultiSetBatch.java	13
java-client/src/main/java/org/apache/pegasus/client/ScanOptions.java	24
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java	165
java-client/src/main/java/org/apache/pegasus/rpc/Cluster.java	16
java-client/src/main/java/org/apache/pegasus/rpc/async/ClusterManager.java	183
java-client/src/main/java/org/apache/pegasus/rpc/async/ThriftFrameEncoder.java	31
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java	421
java-client/src/main/java/org/apache/pegasus/rpc/async/MetaHandler.java	15
java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java	453
java-client/src/main/java/org/apache/pegasus/rpc/async/TByteBufTransport.java	30
java-client/src/main/java/org/apache/pegasus/rpc/async/HostNameResolver.java	33
java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java	255
java-client/src/main/java/org/apache/pegasus/rpc/async/ClientRequestRound.java	72
java-client/src/main/java/org/apache/pegasus/rpc/async/ThriftFrameDecoder.java	78
java-client/src/main/java/org/apache/pegasus/rpc/InternalTableOptions.java	19
java-client/src/main/java/org/apache/pegasus/rpc/Table.java	49
java-client/src/main/java/org/apache/pegasus/rpc/ReplicationException.java	27
java-client/src/main/java/org/apache/pegasus/rpc/ThriftHeader.java	17
java-client/src/main/java/org/apache/pegasus/rpc/Meta.java	6
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/BackupRequestInterceptor.java	55
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptor.java	9
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/TableInterceptor.java	11
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/TableInterceptorManager.java	31
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptorManager.java	36
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/CompressionInterceptor.java	80
java-client/src/main/java/org/apache/pegasus/rpc/KeyHasher.java	12
java-client/src/main/java/org/apache/pegasus/example/FullScanSample.java	41
java-client/src/main/java/org/apache/pegasus/example/BatchSample.java	87
java-client/src/main/java/org/apache/pegasus/base/blob.java	132
java-client/src/main/java/org/apache/pegasus/base/task_code.java	125
java-client/src/main/java/org/apache/pegasus/base/gpid.java	146
java-client/src/main/java/org/apache/pegasus/base/rpc_address.java	170
java-client/src/main/java/org/apache/pegasus/base/error_code.java	216
java-client/src/main/java/org/apache/pegasus/base/host_port.java	176
java-client/dev-support/findbugs-exclude.xml	16
java-client/dev-support/google-checks.xml	233
nodejs-client/src/errors.js	81
nodejs-client/src/dsn/dsn_types.js	278
nodejs-client/src/connection.js	242
nodejs-client/src/table_handler.js	373
nodejs-client/src/client.js	188
nodejs-client/src/operator.js	263
nodejs-client/src/session.js	382
nodejs-client/src/tools.js	91
nodejs-client/index.js	3
nodejs-client/log_config.js	7