Path	Lines of Code
Cargo.toml	74
ballista-cli/Cargo.toml	38
ballista-cli/src/command.rs	200
ballista-cli/src/exec.rs	155
ballista-cli/src/lib.rs	5
ballista-cli/src/main.rs	165
ballista/client/Cargo.toml	47
ballista/client/src/extension.rs	189
ballista/client/src/lib.rs	4
ballista/client/src/prelude.rs	1
ballista/core/Cargo.toml	66
ballista/core/build.rs	33
ballista/core/proto/ballista.proto	603
ballista/core/proto/datafusion.proto	1069
ballista/core/proto/datafusion_common.proto	489
ballista/core/src/client.rs	176
ballista/core/src/config.rs	256
ballista/core/src/consistent_hash/mod.rs	241
ballista/core/src/consistent_hash/node.rs	4
ballista/core/src/diagram.rs	119
ballista/core/src/error.rs	195
ballista/core/src/event_loop.rs	27
ballista/core/src/execution_plans/distributed_query.rs	333
ballista/core/src/execution_plans/mod.rs	8
ballista/core/src/execution_plans/shuffle_reader.rs	613
ballista/core/src/execution_plans/shuffle_writer.rs	491
ballista/core/src/execution_plans/unresolved_shuffle.rs	87
ballista/core/src/extension.rs	331
ballista/core/src/lib.rs	25
ballista/core/src/object_store.rs	238
ballista/core/src/planner.rs	206
ballista/core/src/registry.rs	80
ballista/core/src/serde/mod.rs	231
ballista/core/src/serde/scheduler/from_proto.rs	382
ballista/core/src/serde/scheduler/mod.rs	226
ballista/core/src/serde/scheduler/to_proto.rs	218
ballista/core/src/utils.rs	121
ballista/executor/Cargo.toml	62
ballista/executor/build.rs	8
ballista/executor/executor_config_spec.toml	118
ballista/executor/src/collect.rs	97
ballista/executor/src/config.rs	36
ballista/executor/src/cpu_bound_executor.rs	250
ballista/executor/src/execution_engine.rs	67
ballista/executor/src/execution_loop.rs	267
ballista/executor/src/executor.rs	338
ballista/executor/src/executor_process.rs	578
ballista/executor/src/executor_server.rs	688
ballista/executor/src/flight_service.rs	198
ballista/executor/src/lib.rs	87
ballista/executor/src/metrics/mod.rs	28
ballista/executor/src/shutdown.rs	48
ballista/executor/src/standalone.rs	128
ballista/executor/src/terminate.rs	14
ballista/scheduler/Cargo.toml	72
ballista/scheduler/build.rs	14
ballista/scheduler/proto/keda.proto	50
ballista/scheduler/scheduler_config_spec.toml	144
ballista/scheduler/src/api/handlers.rs	363
ballista/scheduler/src/api/mod.rs	38
ballista/scheduler/src/cluster/event/mod.rs	242
ballista/scheduler/src/cluster/memory.rs	523
ballista/scheduler/src/cluster/mod.rs	809
ballista/scheduler/src/config.rs	237
ballista/scheduler/src/display.rs	121
ballista/scheduler/src/lib.rs	15
ballista/scheduler/src/metrics/mod.rs	34
ballista/scheduler/src/metrics/prometheus.rs	128
ballista/scheduler/src/planner.rs	403
ballista/scheduler/src/scheduler_process.rs	76
ballista/scheduler/src/scheduler_server/event.rs	47
ballista/scheduler/src/scheduler_server/external_scaler.rs	49
ballista/scheduler/src/scheduler_server/grpc.rs	775
ballista/scheduler/src/scheduler_server/mod.rs	584
ballista/scheduler/src/scheduler_server/query_stage_scheduler.rs	380
ballista/scheduler/src/standalone.rs	85
ballista/scheduler/src/state/execution_graph.rs	2094
ballista/scheduler/src/state/execution_graph_dot.rs	623
ballista/scheduler/src/state/execution_stage.rs	721
ballista/scheduler/src/state/executor_manager.rs	347
ballista/scheduler/src/state/mod.rs	388
ballista/scheduler/src/state/session_manager.rs	54
ballista/scheduler/src/state/task_manager.rs	568
benchmarks/Cargo.toml	50
benchmarks/db-benchmark/groupby-datafusion.py	166
benchmarks/db-benchmark/join-datafusion.py	118
benchmarks/queries/q1.sql	21
benchmarks/queries/q10.sql	32
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	33
benchmarks/queries/q19.sql	35
benchmarks/queries/q2.sql	44
benchmarks/queries/q20.sql	37
benchmarks/queries/q21.sql	40
benchmarks/queries/q22.sql	37
benchmarks/queries/q3.sql	23
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	29
dev/create_license.py	27
dev/release/check-rat-report.py	33
dev/release/download-python-wheels.py	80
dev/release/generate-changelog.py	73
dev/update_arrow_deps.py	56
dev/update_ballista_versions.py	65
dev/update_datafusion_versions.py	74
python/Cargo.toml	43
python/ballista/__init__.py	14
python/pyproject.toml	59
python/src/cluster.rs	211
python/src/codec.rs	162
python/src/lib.rs	60
python/src/utils.rs	38
rust-toolchain.toml	18
rustfmt.toml	18