List of all items
Structs
- AvgLatencyMetric
- BroadcastExec
- BytesCounterMetric
- CompressionType
- DefaultChannelResolver
- DefaultSessionBuilder
- DistributedCodec
- DistributedConfig
- DistributedExec
- DistributedLeafExec
- DistributedTaskContext
- DistributedWorkUnitFeedContext
- FirstLatencyMetric
- GetClusterWorkersRequest
- GetClusterWorkersResponse
- GetTaskProgressRequest
- GetTaskProgressResponse
- GetWorkerInfoRequest
- GetWorkerInfoResponse
- MappedWorkerSessionBuilder
- MaxGaugeMetric
- MaxLatencyMetric
- MinLatencyMetric
- NetworkBroadcastExec
- NetworkCoalesceExec
- NetworkShuffleExec
- ObservabilityServiceClient
- ObservabilityServiceImpl
- ObservabilityServiceServer
- P50LatencyMetric
- P75LatencyMetric
- P95LatencyMetric
- P99LatencyMetric
- PingRequest
- PingResponse
- TaskData
- TaskEstimation
- TaskKey
- TaskProgress
- TaskRoutingContext
- WorkUnitFeed
- WorkUnitFeedProto
- Worker
- WorkerMetrics
- WorkerQueryContext
- WorkerServiceClient
- WorkerServiceServer
Enums
Traits
- BytesMetricExt
- ChannelResolver
- DistributedExt
- GaugeMetricExt
- LatencyMetricExt
- MappedWorkerSessionBuilderExt
- NetworkBoundary
- NetworkBoundaryExt
- ObservabilityService
- SessionStateBuilderExt
- TaskEstimator
- WorkUnit
- WorkUnitFeedProvider
- WorkerResolver
- WorkerSessionBuilder
Functions
- create_worker_client
- display_plan_ascii
- display_plan_graphviz
- explain_analyze
- get_distributed_channel_resolver
- get_distributed_worker_resolver
- rewrite_distributed_plan_with_metrics