Class LocalitySchedulingConstraint
- java.lang.Object
-
- org.apache.nemo.runtime.master.scheduler.LocalitySchedulingConstraint
-
- All Implemented Interfaces:
SchedulingConstraint
@ThreadSafe @AssociatedProperty(ResourceLocalityProperty.class) public final class LocalitySchedulingConstraint extends java.lang.Object implements SchedulingConstraint
This policy tries to pick the executors where the corresponding source or intermediate data for a task reside.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
testSchedulability(ExecutorRepresenter executor, Task task)
-
-
-
Method Detail
-
testSchedulability
public boolean testSchedulability(ExecutorRepresenter executor, Task task)
- Specified by:
testSchedulability
in interfaceSchedulingConstraint
-
-