Interface | Description |
---|---|
SchedulingExecutionVertex |
Scheduling representation of
ExecutionVertex . |
SchedulingPipelinedRegion |
Pipelined region on execution level, i.e.,
ExecutionGraph level. |
SchedulingResultPartition |
Representation of
IntermediateResultPartition . |
SchedulingStrategy |
Component which encapsulates the scheduling logic.
|
SchedulingStrategyFactory |
Factory interface for
SchedulingStrategy . |
SchedulingTopology |
Topology of
SchedulingExecutionVertex . |
Class | Description |
---|---|
EagerSchedulingStrategy |
SchedulingStrategy instance for streaming job which will schedule all tasks at the same
time. |
EagerSchedulingStrategy.Factory |
The factory for creating
EagerSchedulingStrategy . |
ExecutionVertexID |
Id identifying
ExecutionVertex . |
InputDependencyConstraintChecker |
A wrapper class for
InputDependencyConstraint checker. |
LazyFromSourcesSchedulingStrategy |
SchedulingStrategy instance for batch job which schedule vertices when input data are
ready. |
LazyFromSourcesSchedulingStrategy.Factory |
The factory for creating
LazyFromSourcesSchedulingStrategy . |
PipelinedRegionSchedulingStrategy |
SchedulingStrategy instance which schedules tasks in granularity of pipelined regions. |
PipelinedRegionSchedulingStrategy.Factory |
The factory for creating
PipelinedRegionSchedulingStrategy . |
Enum | Description |
---|---|
ResultPartitionState |
State of a
SchedulingResultPartition . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.