path	# lines of code
redolog/file_redolog_manager.go	291
redolog/redolog_manager.go	22
redolog/redolog_manager_master.go	108
redolog/composite_redolog_manager.go	97
redolog/kafka_redolog_manager.go	262
cluster/types.go	21
cluster/shard/types.go	6
cluster/shard/shardset.go	52
cluster/topology/options.go	134
cluster/topology/host.go	48
cluster/topology/dynamic.go	211
cluster/topology/healthtracking_dynamic.go	90
cluster/topology/types.go	100
cluster/topology/static.go	38
cluster/topology/shard_owner.go	28
cluster/topology/map.go	78
cluster/topology/testutil/topology.go	74
cluster/kvstore/etcd.go	53
cluster/kvstore/transaction.go	38
utils/serialization.go	290
utils/slices.go	17
utils/config.go	8
utils/time.go	70
utils/options.go	40
utils/sync.go	7
utils/table_writer.go	76
utils/reflection.go	14
utils/resource_mapper.go	41
utils/file_system.go	41
utils/stream_serialization.go	170
utils/env.go	54
utils/io.go	13
utils/consistenthasing/consistenthashing.go	63
utils/memory.go	37
utils/kafka.go	10
utils/http.go	255
utils/hash.go	159
utils/di.go	52
utils/constants.go	4
utils/uuid.go	17
utils/key.go	56
utils/error.go	74
utils/sort_utils.go	9
utils/hll.go	18
utils/metrics.go	1164
metastore/schema_fetch.go	188
metastore/validator.go	193
metastore/disk_metastore.go	1092
metastore/common/data_type.go	33
metastore/common/errors.go	42
metastore/common/types.go	43
metastore/common/model.go	76
api/data_request.go	6
api/sql_query_handler.go	53
api/debug_handler.go	629
api/common/query_response.go	7
api/common/query_request.go	37
api/common/response.go	10
api/common/error.go	51
api/common/request.go	115
api/debug_request.go	73
api/schema_request.go	44
api/health_check_handler.go	27
api/schema_handler.go	145
api/panic_handler.go	28
api/query_handler.go	319
api/ui/debug/redologs.html	62
api/ui/debug/archive.html	47
api/ui/debug/summary.html	56
api/ui/debug/snapshot.html	40
api/ui/debug/index.html	59
api/ui/debug/purge.html	83
api/ui/debug/bootstrap.html	36
api/ui/debug/backfill.html	62
api/ui/debug/batch.html	62
api/ui/debug/memory.html	43
api/ui/debug/css/index.css	2
api/ui/debug/css/batch.css	56
api/ui/debug/js/backfill.js	236
api/ui/debug/js/redologs.js	131
api/ui/debug/js/summary.js	100
api/ui/debug/js/batch.js	350
api/ui/debug/js/snapshot.js	109
api/ui/debug/js/index.js	18
api/ui/debug/js/utils.js	13
api/ui/debug/js/archive.js	156
api/ui/debug/js/memory.js	122
api/ui/debug/js/purge.js	171
api/ui/swagger/index.html	29
api/enum_handler.go	63
api/doc.go	1
api/data_handler.go	53
api/error.go	43
api/debug_response.go	24
api/schema_response.go	15
cgoutils/utils.go	15
cgoutils/memory/rmm_alloc.cu	267
cgoutils/memory/cuda_malloc.cu	201
cgoutils/memory/malloc.c	121
cgoutils/utils.h	7
cgoutils/memory.h	56
cgoutils/memory.go	122
datanode/bootstrap_manager.go	123
datanode/options.go	55
datanode/bootstrap/options.go	42
datanode/bootstrap/bootstrap_server.go	523
datanode/bootstrap/bootstrap_details.go	76
datanode/bootstrap/types.go	50
datanode/types.go	34
datanode/peer_source.go	186
datanode/client/types.go	23
datanode/client/query_client.go	129
datanode/datanode.go	596
memstore/merge.go	405
memstore/memstore.go	244
memstore/options.go	20
memstore/host_memory_manager.go	461
memstore/cuckoo_index.go	446
memstore/ingestion.go	352
memstore/common/upsert_batch.go	372
memstore/common/host_memory_manager.go	16
memstore/common/batch.go	72
memstore/common/job.go	8
memstore/common/data_type.go	498
memstore/common/types.go	16
memstore/common/upsert_batch_header.go	126
memstore/common/vector_party_serializer.go	138
memstore/common/upsert_batch_builder.go	402
memstore/common/vector_party.go	103
memstore/common/pinnable.go	32
memstore/common/common.go	41
memstore/common/data_value.go	833
memstore/common/primary_key.go	70
memstore/common/schema.go	174
memstore/archiving.go	327
memstore/redo_log_browser.go	114
memstore/job_manager.go	412
memstore/job_status.go	87
memstore/table_shard.go	111
memstore/archive_vector_party.go	80
memstore/scheduler.go	221
memstore/snapshot.go	76
memstore/backfill_manager.go	150
memstore/batchstats.go	88
memstore/vectors/vector.go	203
memstore/purge.go	90
memstore/vector_party.go	478
memstore/backfill.go	480
memstore/snapshot_manager.go	87
memstore/list/slab.go	298
memstore/list/memory_pool.go	120
memstore/list/archive_vector_party.go	321
memstore/list/vector_party.go	121
memstore/list/live_vector_party.go	320
memstore/bootstrap.go	528
memstore/purge_manager.go	25
memstore/live_vector_party.go	276
memstore/recovery.go	361
memstore/live_store.go	309
memstore/schema.go	223
memstore/archive_store.go	256
common/config.go	69
common/log.go	109
common/metrics.go	16
cmd/aresd/main.go	5
cmd/aresd/cmd/cmd.go	261
cmd/aresd/cmd/config_parser.go	47
cmd/subscriber/main.go	122
cmd/controller/main.go	5
cmd/controller/cmd/cmd.go	92
cmd/broker/main.go	5
cmd/broker/cmd/cmd.go	169
cmd/arescli/main.go	141
diskstore/diskstore.go	30
diskstore/local_diskstore.go	338
diskstore/diskstore_util.go	88
query/algorithm_unittest.cu	1721
query/dimension_transform.cu	84
query/context/query_context_helper.go	645
query/context/query_context_options.go	12
query/concurrent_unordered_map.hpp	122
query/geo_intersects.cu	306
query/algorithm.cu	38
query/memory.cu	56
query/time_series_aggregate.h	342
query/time_series_aggregate.go	667
query/expression_vm.h	61
query/iterator.cu	34
query/utils.cu	206
query/expr/parser.go	470
query/expr/scanner.go	421
query/expr/token.go	292
query/expr/ast.go	477
query/functor_unittest.cu	1038
query/common/dim_util.go	48
query/common/time_filter.go	326
query/common/constant.go	21
query/common/aql_query_result.go	68
query/common/dimval.go	162
query/common/aql.go	65
query/common/time_bucketizer.go	94
query/common/hll.go	813
query/device_manager.go	192
query/utils.hpp	235
query/aql_postprocessor.go	193
query/aql_context.go	215
query/transform.hpp	133
query/hll.cu	270
query/scratch_space_transform.cu	43
query/aql_batchexecutor.go	188
query/device_allocator.go	136
query/unittest_utils.hpp	271
query/aql_processor.go	1150
query/functor.hpp	1103
query/aql_compiler.go	1122
query/stats.go	180
query/binder.hpp	628
query/functor.cu	230
query/aql_nonaggr_batchexecutor.go	74
query/measure_transform.cu	44
query/time_bucketizer.go	233
query/memory.hpp	70
query/algorithm.hpp	56
query/filter.cu	232
query/hash_lookup.cu	143
query/hash_reduction.cu	357
query/transform.cu	83
query/sql/tree/JoinUsing.go	17
query/sql/tree/Relation.go	15
query/sql/tree/JoinCriteria.go	4
query/sql/tree/SimpleGroupBy.go	20
query/sql/tree/LogicalBinaryExpression.go	40
query/sql/tree/Table.go	14
query/sql/tree/Query.go	24
query/sql/tree/NaturalJoin.go	10
query/sql/tree/GroupingElement.go	15
query/sql/tree/Node.go	28
query/sql/tree/Identifier.go	16
query/sql/tree/JoinOn.go	19
query/sql/tree/OrderBy.go	14
query/sql/tree/GroupBy.go	16
query/sql/tree/AliasedRelation.go	27
query/sql/tree/AstVisitor.go	28
query/sql/tree/Select.go	16
query/sql/tree/SelectItem.go	15
query/sql/tree/TableSubquery.go	14
query/sql/tree/WithQuery.go	24
query/sql/tree/Expression.go	15
query/sql/tree/Join.go	48
query/sql/tree/SingleColumn.go	16
query/sql/tree/With.go	16
query/sql/tree/Statement.go	15
query/sql/tree/QueryBody.go	16
query/sql/tree/AllColumns.go	14
query/sql/tree/SortItem.go	25
query/sql/tree/QualifiedName.go	15
query/sql/tree/QuerySpecification.go	33
query/sql/antlrgen/sqlbase_visitor.go	92
query/sql/antlrgen/sqlbase_base_visitor.go	266
query/sql/antlrgen/sqlbase_lexer.go	1226
query/sql/SqlBase.g4	519
query/sql/util/util.go	22
query/sql/util/caseInsensitiveStream.go	24
query/sql/util/udfRegister.go	52
query/sql/sql_parser.go	1542
query/sort_reduce.cu	291
query/iterator_unittest.cu	606
query/hll.go	74
query/iterator.hpp	1195
subscriber/common/rules/job_config.go	273
subscriber/common/rules/transformation.go	21
subscriber/common/job/retry_failure_handler.go	75
subscriber/common/job/controller.go	435
subscriber/common/job/driver.go	388
subscriber/common/job/failure_handler.go	9
subscriber/common/job/processor.go	39
subscriber/common/job/streaming_processor.go	416
subscriber/common/message/message_parser.go	138
subscriber/common/message/message_decoder.go	63
subscriber/common/message/json_decoder.go	27
subscriber/common/sink/ares_database.go	62
subscriber/common/sink/sink.go	80
subscriber/common/sink/kafka.go	138
subscriber/common/consumer/kafka/kafka.go	284
subscriber/common/consumer/consumer.go	21
subscriber/common/tools/util.go	22
subscriber/common/tools/batcher.go	75
subscriber/config/test-kafka.yaml	45
subscriber/config/service_config.go	176
subscriber/config/test-controller-disable.yaml	29
subscriber/config/test-ares-cluster-empty.yaml	19
subscriber/config/test-job-empty.yaml	24
subscriber/config/test-ares-ns-empty.yaml	26
controller/models/job.go	48
controller/models/subscriber.go	5
controller/models/assignment.go	6
controller/models/Instance.go	7
controller/models/defaults.go	41
controller/tasks/common/errors.go	5
controller/tasks/common/types.go	23
controller/tasks/Module.go	48
controller/tasks/etcd/ingestion_assignment.go	353
controller/tasks/etcd/leader_elector.go	73
controller/client/controller.go	202
controller/ui/src/index.css	13
controller/ui/src/index.js	10
controller/ui/src/App.js	457
controller/ui/src/serviceWorker.js	92
controller/ui/src/App.css	23
controller/ui/public/index.html	18
controller/ui/swagger/index.html	29
controller/mutators/common/job_config_validator.go	23
controller/mutators/common/errors.go	43
controller/mutators/common/types.go	63
controller/mutators/module.go	41
controller/mutators/etcd/job_mutator.go	150
controller/mutators/etcd/assignment_mutator.go	137
controller/mutators/etcd/enum_mutator.go	239
controller/mutators/etcd/subscriber_mutator.go	84
controller/mutators/etcd/schema_mutator.go	243
controller/mutators/etcd/namespace_mutator.go	48
controller/mutators/etcd/membership_mutator.go	92
controller/mutators/etcd/placement_mutator.go	167
controller/mutators/etcd/common.go	93
controller/handlers/config.go	205
controller/handlers/assignment.go	133
controller/handlers/composite.go	36
controller/handlers/ui.go	62
controller/handlers/module.go	14
controller/handlers/namespace.go	53
controller/handlers/membership.go	153
controller/handlers/placement.go	192
controller/handlers/models.go	166
controller/handlers/doc.go	1
controller/handlers/error.go	54
controller/handlers/schema.go	203
controller/handlers/health.go	16
testing/utils.go	36
client/connector.go	420
client/schema.go	346
integration/config/ares.yaml	42
broker/query_plan_non_agg.go	254
broker/query_plan_agg.go	408
broker/common/constant.go	19
broker/common/types.go	26
broker/util/assignment.go	38
broker/query_compiler.go	327
broker/result_merge.go	111
broker/broker_schema_mutator.go	127
broker/handler.go	118
broker/executor.go	47
broker/config/config.go	9
config/ares.yaml	43
config/ares-broker.yaml	21
config/ares-controller.yaml	22