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.