List of all items
Structs
- cluster::BallistaCluster
- cluster::TopologyNode
- cluster::event::EventSubscriber
- cluster::memory::InMemoryClusterState
- cluster::memory::InMemoryJobState
- config::Config
- config::SchedulerConfig
- display::DisplayableBallistaExecutionPlan
- metrics::NoopMetricsCollector
- planner::DefaultDistributedPlanner
- scheduler_server::SchedulerServer
- state::SchedulerState
- state::execution_graph::ExecutionGraph
- state::execution_graph::RunningTaskInfo
- state::execution_graph::TaskDescription
- state::execution_graph_dot::ExecutionGraphDot
- state::execution_stage::FailedStage
- state::execution_stage::ResolvedStage
- state::execution_stage::RunningStage
- state::execution_stage::StageOutput
- state::execution_stage::SuccessfulStage
- state::execution_stage::TaskInfo
- state::execution_stage::UnresolvedStage
- 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
- cluster::ClusterStateEvent
- cluster::ClusterStorage
- cluster::JobStateEvent
- config::ArgParseError
- config::EnvParseError
- config::Error
- config::TaskDistribution
- config::TaskDistributionPolicy
- config::ValidationError
- scheduler_server::event::QueryStageSchedulerEvent
- state::execution_stage::ExecutionStage
Traits
- cluster::ClusterState
- cluster::DistributionPolicy
- cluster::JobState
- config::ResultExt
- metrics::SchedulerMetricsCollector
- planner::DistributedPlanner
- state::task_manager::TaskLauncher
Functions
- display::print_stage_metrics
- metrics::default_metrics_collector
- planner::find_unresolved_shuffles
- planner::remove_unresolved_shuffles
- planner::rollback_resolved_shuffles
- scheduler_process::create_scheduler
- scheduler_process::start_grpc_service
- scheduler_process::start_server
- scheduler_server::timestamp_millis
- scheduler_server::timestamp_secs
- standalone::new_standalone_scheduler
- standalone::new_standalone_scheduler_from_state
- standalone::new_standalone_scheduler_with_builder
- state::decode_into
- state::decode_protobuf
- state::encode_protobuf
- state::execution_graph::create_task_info
- state::session_manager::create_datafusion_context
Type Aliases
- cluster::BoundTask
- cluster::ClusterStateEventStream
- cluster::ExecutorHeartbeatStream
- cluster::ExecutorSlot
- cluster::JobStateEventStream
- scheduler_server::SessionBuilder