List of all items
Structs
- AvgLatencyMetric
- BroadcastExec
- BytesCounterMetric
- CompressionType
- DefaultSessionBuilder
- DesiredTaskCountEvent
- DesiredTaskCountEventResponse
- DistributedCodec
- DistributedConfig
- DistributedExec
- DistributedLeafExec
- DistributedTaskContext
- DistributedWorkUnitFeedContext
- ExecuteTaskRequest
- FirstLatencyMetric
- GetWorkerInfoRequest
- GetWorkerInfoResponse
- LoadInfo
- LocalWorkerContext
- MappedWorkerSessionBuilder
- MaxGaugeMetric
- MaxLatencyMetric
- MinLatencyMetric
- NetworkBroadcastExec
- NetworkCoalesceExec
- NetworkShuffleExec
- P50LatencyMetric
- P75LatencyMetric
- P95LatencyMetric
- P99LatencyMetric
- RouteTasksEvent
- RouteTasksEventResponse
- ScaleUpLeafNodeEvent
- ScaleUpLeafNodeEventResponse
- SetPlanRequest
- TaskData
- TaskKey
- TaskMetrics
- WorkUnitBatch
- WorkUnitFeed
- WorkUnitFeedDeclaration
- WorkUnitFeedProto
- WorkUnitMsg
- Worker
- WorkerPlanRewriteEvent
- WorkerPlanRewriteEventResponse
- WorkerQueryContext
- grpc::DefaultChannelResolver
- grpc::GetClusterWorkersRequest
- grpc::GetClusterWorkersResponse
- grpc::GetTaskProgressRequest
- grpc::GetTaskProgressResponse
- grpc::ObservabilityServiceClient
- grpc::ObservabilityServiceImpl
- grpc::ObservabilityServiceServer
- grpc::PingRequest
- grpc::PingResponse
- grpc::TaskProgress
- grpc::WorkerMetrics
Enums
- CoordinatorToWorkerMsg
- DistributedMetricsFormat
- ProducerHeadSpec
- Stage
- TaskCountAnnotation
- WorkerToCoordinatorMsg
- grpc::TaskStatus
Traits
- BytesMetricExt
- ChannelResolver
- DesiredTaskCountHandler
- DistributedExt
- DistributedGetterExt
- GaugeMetricExt
- LatencyMetricExt
- MappedWorkerSessionBuilderExt
- NetworkBoundary
- NetworkBoundaryExt
- RouteTasksHandler
- ScaleUpLeafNodeHandler
- SessionStateBuilderExt
- WorkUnit
- WorkUnitFeedProvider
- WorkerChannel
- WorkerPlanRewriteHandler
- WorkerResolver
- WorkerSessionBuilder
- grpc::ObservabilityService
Functions
- display_plan_ascii
- display_plan_graphviz
- explain_analyze
- get_distributed_channel_resolver
- get_distributed_worker_resolver
- grpc::create_worker_client
- rewrite_distributed_plan_with_metrics