List of all items
Structs
- cluster::BallistaCluster
- cluster::TopologyNode
- cluster::event::EventSubscriber
- cluster::kv::KeyValueState
- cluster::memory::InMemoryClusterState
- cluster::memory::InMemoryJobState
- cluster::storage::etcd::EtcdClient
- cluster::storage::sled::SledClient
- config::SchedulerConfig
- display::DisplayableBallistaExecutionPlan
- flight_sql::FlightSqlServiceImpl
- metrics::NoopMetricsCollector
- planner::DistributedPlanner
- scheduler_server::SchedulerServer
- scheduler_server::externalscaler::GetMetricSpecResponse
- scheduler_server::externalscaler::GetMetricsRequest
- scheduler_server::externalscaler::GetMetricsResponse
- scheduler_server::externalscaler::IsActiveResponse
- scheduler_server::externalscaler::MetricSpec
- scheduler_server::externalscaler::MetricValue
- scheduler_server::externalscaler::ScaledObjectRef
- scheduler_server::externalscaler::external_scaler_client::ExternalScalerClient
- scheduler_server::externalscaler::external_scaler_server::ExternalScalerServer
- state::SchedulerState
- state::execution_graph::ExecutionGraph
- state::execution_graph::RunningTaskInfo
- state::execution_graph::TaskDescription
- state::execution_graph_dot::ExecutionGraphDot
- state::executor_manager::ExecutorManager
- state::session_manager::SessionManager
- state::task_manager::JobInfoCache
- state::task_manager::JobOverview
- state::task_manager::TaskManager
- state::task_manager::UpdatedStages
Enums
- api::EitherBody
- cluster::ClusterStorage
- cluster::JobStateEvent
- cluster::storage::Keyspace
- cluster::storage::Operation
- cluster::storage::WatchEvent
- config::ClusterStorageConfig
- config::TaskDistribution
- config::TaskDistributionPolicy
- scheduler_server::event::QueryStageSchedulerEvent
Traits
- cluster::ClusterState
- cluster::JobState
- cluster::storage::KeyValueStore
- cluster::storage::Lock
- cluster::storage::Watch
- metrics::SchedulerMetricsCollector
- scheduler_server::externalscaler::external_scaler_server::ExternalScaler
- state::task_manager::TaskLauncher
Functions
- api::get_routes
- display::print_stage_metrics
- metrics::default_metrics_collector
- planner::find_unresolved_shuffles
- planner::remove_unresolved_shuffles
- planner::rollback_resolved_shuffles
- scheduler_process::start_server
- scheduler_server::timestamp_millis
- scheduler_server::timestamp_secs
- standalone::new_standalone_scheduler
- state::decode_into
- state::decode_protobuf
- state::encode_protobuf
- state::session_manager::create_datafusion_context
Type Aliases
- api::Error
- api::HttpBody
- cluster::BoundTask
- cluster::ExecutorHeartbeatStream
- cluster::ExecutorSlot
- cluster::JobStateEventStream