| Class | Description |
|---|---|
| BoundedSourceTask<O> |
BoundedSourceTask.
|
| MetricCollectionBarrierTask |
MetricCollectionBarrierTask.
|
| OperatorTask |
OperatorTask.
|
| PhysicalPlan |
A job's physical plan, to be executed by the Runtime.
|
| PhysicalPlanGenerator |
A function that converts an IR DAG to physical DAG.
|
| PhysicalStage |
PhysicalStage.
|
| PhysicalStageEdge |
Contains information stage boundary
StageEdge. |
| ScheduledTaskGroup |
A ScheduledTaskGroup is a grouping of
Task that belong to a stage. |
| Task |
Task.
|
| UnboundedSourceTask |
UnboundedSourceTask.
|
Copyright © 2018. All rights reserved.