Path	Lines of Code
Cargo.toml	61
ballista-cli/Cargo.toml	41
ballista-cli/src/command.rs	193
ballista-cli/src/exec.rs	137
ballista-cli/src/lib.rs	5
ballista-cli/src/main.rs	149
ballista/client/Cargo.toml	46
ballista/client/src/columnar_batch.rs	122
ballista/client/src/context.rs	852
ballista/client/src/lib.rs	4
ballista/client/src/prelude.rs	12
ballista/core/Cargo.toml	78
ballista/core/build.rs	30
ballista/core/proto/ballista.proto	616
ballista/core/proto/datafusion.proto	1142
ballista/core/src/cache_layer/medium/local_disk.rs	23
ballista/core/src/cache_layer/medium/local_memory.rs	26
ballista/core/src/cache_layer/medium/mod.rs	9
ballista/core/src/cache_layer/mod.rs	91
ballista/core/src/cache_layer/object_store/file.rs	213
ballista/core/src/cache_layer/object_store/mod.rs	115
ballista/core/src/cache_layer/policy/file.rs	235
ballista/core/src/cache_layer/policy/mod.rs	1
ballista/core/src/client.rs	159
ballista/core/src/config.rs	309
ballista/core/src/consistent_hash/mod.rs	241
ballista/core/src/consistent_hash/node.rs	4
ballista/core/src/error.rs	192
ballista/core/src/event_loop.rs	27
ballista/core/src/execution_plans/distributed_query.rs	281
ballista/core/src/execution_plans/mod.rs	8
ballista/core/src/execution_plans/shuffle_reader.rs	583
ballista/core/src/execution_plans/shuffle_writer.rs	442
ballista/core/src/execution_plans/unresolved_shuffle.rs	80
ballista/core/src/lib.rs	18
ballista/core/src/object_store_registry/cache.rs	55
ballista/core/src/object_store_registry/mod.rs	112
ballista/core/src/plugin/mod.rs	66
ballista/core/src/plugin/plugin_manager.rs	104
ballista/core/src/plugin/udf.rs	104
ballista/core/src/serde/mod.rs	245
ballista/core/src/serde/scheduler/from_proto.rs	376
ballista/core/src/serde/scheduler/mod.rs	263
ballista/core/src/serde/scheduler/to_proto.rs	207
ballista/core/src/utils.rs	304
ballista/executor/Cargo.toml	70
ballista/executor/build.rs	6
ballista/executor/executor_config_spec.toml	136
ballista/executor/src/collect.rs	87
ballista/executor/src/cpu_bound_executor.rs	236
ballista/executor/src/execution_engine.rs	80
ballista/executor/src/execution_loop.rs	249
ballista/executor/src/executor.rs	307
ballista/executor/src/executor_process.rs	532
ballista/executor/src/executor_server.rs	698
ballista/executor/src/flight_service.rs	43
ballista/executor/src/lib.rs	77
ballista/executor/src/metrics/mod.rs	28
ballista/executor/src/shutdown.rs	48
ballista/executor/src/standalone.rs	78
ballista/executor/src/terminate.rs	14
ballista/scheduler/Cargo.toml	82
ballista/scheduler/build.rs	10
ballista/scheduler/proto/keda.proto	50
ballista/scheduler/scheduler_config_spec.toml	156
ballista/scheduler/src/api/handlers.rs	326
ballista/scheduler/src/api/mod.rs	107
ballista/scheduler/src/cluster/event/mod.rs	242
ballista/scheduler/src/cluster/kv.rs	678
ballista/scheduler/src/cluster/memory.rs	444
ballista/scheduler/src/cluster/mod.rs	835
ballista/scheduler/src/cluster/storage/etcd.rs	225
ballista/scheduler/src/cluster/storage/mod.rs	30
ballista/scheduler/src/cluster/storage/sled.rs	213
ballista/scheduler/src/config.rs	147
ballista/scheduler/src/display.rs	125
ballista/scheduler/src/flight_sql.rs	461
ballista/scheduler/src/lib.rs	16
ballista/scheduler/src/metrics/mod.rs	34
ballista/scheduler/src/metrics/prometheus.rs	128
ballista/scheduler/src/planner.rs	528
ballista/scheduler/src/scheduler_process.rs	89
ballista/scheduler/src/scheduler_server/event.rs	47
ballista/scheduler/src/scheduler_server/external_scaler.rs	49
ballista/scheduler/src/scheduler_server/grpc.rs	834
ballista/scheduler/src/scheduler_server/mod.rs	584
ballista/scheduler/src/scheduler_server/query_stage_scheduler.rs	382
ballista/scheduler/src/standalone.rs	49
ballista/scheduler/src/state/execution_graph.rs	2279
ballista/scheduler/src/state/execution_graph/execution_stage.rs	927
ballista/scheduler/src/state/execution_graph_dot.rs	616
ballista/scheduler/src/state/executor_manager.rs	346
ballista/scheduler/src/state/mod.rs	364
ballista/scheduler/src/state/session_manager.rs	59
ballista/scheduler/src/state/task_manager.rs	597
ballista/scheduler/ui/public/index.html	20
ballista/scheduler/ui/src/App.css	1
ballista/scheduler/ui/src/App.tsx	80
ballista/scheduler/ui/src/components/DataTable.tsx	169
ballista/scheduler/ui/src/components/Empty.tsx	18
ballista/scheduler/ui/src/components/ExecutorsList.tsx	50
ballista/scheduler/ui/src/components/Footer.tsx	16
ballista/scheduler/ui/src/components/Header.tsx	64
ballista/scheduler/ui/src/components/JobStagesMetrics.tsx	68
ballista/scheduler/ui/src/components/QueriesList.tsx	232
ballista/scheduler/ui/src/components/Summary.tsx	69
ballista/scheduler/ui/src/index.css	11
ballista/scheduler/ui/src/index.tsx	18
ballista/scheduler/ui/src/reportWebVitals.ts	13
ballista/scheduler/ui/src/setupTests.ts	1
benchmarks/Cargo.toml	54
benchmarks/db-benchmark/groupby-datafusion.py	166
benchmarks/db-benchmark/join-datafusion.py	118
benchmarks/queries/q1.sql	21
benchmarks/queries/q10.sql	31
benchmarks/queries/q11.sql	27
benchmarks/queries/q12.sql	30
benchmarks/queries/q13.sql	20
benchmarks/queries/q14.sql	13
benchmarks/queries/q15.sql	31
benchmarks/queries/q16.sql	30
benchmarks/queries/q17.sql	17
benchmarks/queries/q18.sql	32
benchmarks/queries/q19.sql	35
benchmarks/queries/q2.sql	43
benchmarks/queries/q20.sql	37
benchmarks/queries/q21.sql	39
benchmarks/queries/q22.sql	37
benchmarks/queries/q3.sql	22
benchmarks/queries/q4.sql	21
benchmarks/queries/q5.sql	24
benchmarks/queries/q6.sql	9
benchmarks/queries/q7.sql	39
benchmarks/queries/q8.sql	37
benchmarks/queries/q9.sql	32
benchmarks/spark/src/main/scala/org/apache/arrow/SparkTpch.scala	222
benchmarks/tpch.py	28
ci/conda_env_archery.yml	13
ci/conda_env_cpp.yml	25
ci/conda_env_gandiva.yml	2
ci/conda_env_gandiva_win.yml	2
ci/conda_env_python.yml	14
ci/conda_env_r.yml	19
ci/conda_env_sphinx.yml	5
ci/conda_env_unix.yml	4
ci/detect-changes.py	234
ci/etc/hdfs-site.xml	36
ci/vcpkg/arm64-linux-static-debug.cmake	26
ci/vcpkg/arm64-linux-static-release.cmake	26
ci/vcpkg/x64-linux-static-debug.cmake	21
ci/vcpkg/x64-linux-static-release.cmake	21
ci/vcpkg/x64-osx-static-debug.cmake	22
ci/vcpkg/x64-osx-static-release.cmake	22
ci/vcpkg/x64-windows-static-md-debug.cmake	20
ci/vcpkg/x64-windows-static-md-release.cmake	20
dev/create_license.py	27
dev/release/check-rat-report.py	33
dev/release/download-python-wheels.py	80
dev/update_arrow_deps.py	56
dev/update_ballista_versions.py	65
dev/update_datafusion_versions.py	74
helm/ballista/Chart.yaml	10
helm/ballista/templates/_helpers.tpl	70
helm/ballista/templates/executor.yaml	104
helm/ballista/templates/hpa.yaml	44
helm/ballista/templates/ingress.yaml	77
helm/ballista/templates/scheduler.yaml	103
helm/ballista/templates/serviceaccount.yaml	28
helm/ballista/values.yaml	57
rustfmt.toml	22