List of all items

Structs

• cluster::NodeId
• cluster::NodeState
• config::DistConfig
• event::EventHandler
• executor::DefaultExecutor
• heartbeat::Heartbeater
• network::ScheduledTasks
• network::StageInfo
• network::TaskSetInfo
• physical_plan::ProxyExec
• physical_plan::UnresolvedExec
• planner::DefaultPlanner
• planner::DisplayableStagePlans
• planner::StageId
• planner::TaskId
• runtime::DistRuntime
• runtime::StageState
• runtime::TaskMetrics
• runtime::TaskSet
• runtime::TaskStream
• scheduler::DefaultScheduler
• scheduler::DisplayableTaskDistribution
• util::ReceiverStreamBuilder

Enums

• DistError
• cluster::NodeStatus
• event::Event

Traits

• cluster::DistCluster
• executor::DistExecutor
• network::DistNetwork
• planner::DistPlanner
• scheduler::DistScheduler

Functions

• event::check_job_completed
• event::cleanup_job
• event::local_stage_stats
• event::start_event_handler
• executor::logging_executor_metrics
• planner::check_initial_stage_plans
• planner::is_plan_children_can_be_stages
• planner::resolve_stage_plan
• scheduler::contains_large_memory_datasource
• scheduler::is_one_stage_one_partition_job
• scheduler::is_plan_fully_pipelined
• util::get_local_ip
• util::timestamp_ms

Type Aliases

• DistResult
• RecordBatchStream
• scheduler::AssignSelfFn