org.apache.flink.runtime.jobmanager.scheduler

Class ScheduledUnit

java.lang.Object

org.apache.flink.runtime.jobmanager.scheduler.ScheduledUnit

public class ScheduledUnit
extends Object

Constructor Summary

Constructors

Constructor and Description
ScheduledUnit(Execution task)
ScheduledUnit(Execution task, SlotSharingGroup sharingUnit)
ScheduledUnit(Execution task, SlotSharingGroup sharingUnit, CoLocationConstraint locationConstraint)

Method Summary

Modifier and Type	Method and Description
JobVertexID	getJobVertexId()
CoLocationConstraint	getLocationConstraint()
SlotSharingGroup	getSlotSharingGroup()
Execution	getTaskToExecute()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ScheduledUnit

public ScheduledUnit(Execution task)

ScheduledUnit

public ScheduledUnit(Execution task,
                     SlotSharingGroup sharingUnit)

ScheduledUnit

public ScheduledUnit(Execution task,
                     SlotSharingGroup sharingUnit,
                     CoLocationConstraint locationConstraint)

Method Detail

getJobVertexId

public JobVertexID getJobVertexId()

getTaskToExecute

public Execution getTaskToExecute()

getSlotSharingGroup

public SlotSharingGroup getSlotSharingGroup()

getLocationConstraint

public CoLocationConstraint getLocationConstraint()

toString

public String toString()

Overrides:

toString in class Object