List of all items
Structs
- coordinator::Coordinator
- coordinator::CoordinatorConfig
- coordinator::CoordinatorProgress
- coordinator::WorkerInfo
- flight::client::FlightClient
- flight::client::FlightClientPool
- flight::server::FlightServer
- flight::wire::ExecuteTaskRequest
- flight::wire::ExecuteTaskResponse
- partition::HashPartitioner
- partition::LoadBalancedPartitioner
- partition::Partition
- partition::RangePartitioner
- partition::SpatialExtent
- partition::StripPartitioner
- partition::TilePartitioner
- shuffle::BroadcastShuffle
- shuffle::HashShuffle
- shuffle::RangeShuffle
- shuffle::ShuffleConfig
- shuffle::ShuffleResult
- shuffle::ShuffleStats
- task::PartitionId
- task::Task
- task::TaskContext
- task::TaskId
- task::TaskResult
- task::TaskScheduler
- worker::Worker
- worker::WorkerConfig
- worker::WorkerHealthCheck
- worker::WorkerMetrics
Enums
- error::DistributedError
- partition::PartitionStrategy
- shuffle::ShuffleKey
- shuffle::ShuffleType
- task::TaskOperation
- task::TaskStatus
- worker::WorkerStatus
Functions
- flight::wire::decode_batch_ipc
- flight::wire::decode_execute_request
- flight::wire::decode_execute_response
- flight::wire::encode_batch_ipc
- flight::wire::encode_execute_request
- flight::wire::encode_execute_response
- operations::apply_filter
- operations::calculate_index
- operations::clip_bbox