Class SchedulingConstraintRegistry
- java.lang.Object
-
- org.apache.nemo.runtime.master.scheduler.SchedulingConstraintRegistry
-
@ThreadSafe public final class SchedulingConstraintRegistry extends java.lang.Object
Registry forSchedulingConstraint
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Optional<SchedulingConstraint>
get(java.lang.Class<? extends VertexExecutionProperty> propertyClass)
ReturnsSchedulingConstraint
for the givenVertexExecutionProperty
.void
registerSchedulingConstraint(SchedulingConstraint policy)
Registers aSchedulingConstraint
.
-
-
-
Method Detail
-
registerSchedulingConstraint
public void registerSchedulingConstraint(SchedulingConstraint policy)
Registers aSchedulingConstraint
.- Parameters:
policy
- the policy to register
-
get
public java.util.Optional<SchedulingConstraint> get(java.lang.Class<? extends VertexExecutionProperty> propertyClass)
ReturnsSchedulingConstraint
for the givenVertexExecutionProperty
.- Parameters:
propertyClass
-VertexExecutionProperty
class- Returns:
- the corresponding
SchedulingConstraint
object, orOptional.EMPTY
if no such policy was found
-
-