org.apache.flink.runtime.jobmanager.scheduler

Class ScheduledUnit

java.lang.Object

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

public class ScheduledUnit
extends Object

ScheduledUnit contains the information necessary to allocate a slot for the given task.

Constructor Summary

Constructors

Constructor and Description
ScheduledUnit(Execution task)
ScheduledUnit(Execution task, SlotSharingGroupId slotSharingGroupId)
ScheduledUnit(Execution task, SlotSharingGroupId slotSharingGroupId, CoLocationConstraint coLocationConstraint)
ScheduledUnit(ExecutionVertexID executionVertexId, SlotSharingGroupId slotSharingGroupId, CoLocationConstraint coLocationConstraint)
ScheduledUnit(JobVertexID jobVertexId, SlotSharingGroupId slotSharingGroupId, CoLocationConstraint coLocationConstraint)

Method Summary

Modifier and Type	Method and Description
CoLocationConstraint	getCoLocationConstraint()
JobVertexID	getJobVertexId()
SlotSharingGroupId	getSlotSharingGroupId()
int	getSubtaskIndex()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledUnit

@VisibleForTesting
public ScheduledUnit(Execution task)

ScheduledUnit

public ScheduledUnit(Execution task,
                     SlotSharingGroupId slotSharingGroupId)

ScheduledUnit

public ScheduledUnit(Execution task,
                     SlotSharingGroupId slotSharingGroupId,
                     @Nullable
                     CoLocationConstraint coLocationConstraint)

ScheduledUnit

@VisibleForTesting
public ScheduledUnit(JobVertexID jobVertexId,
                                        SlotSharingGroupId slotSharingGroupId,
                                        @Nullable
                                        CoLocationConstraint coLocationConstraint)

ScheduledUnit

public ScheduledUnit(ExecutionVertexID executionVertexId,
                     SlotSharingGroupId slotSharingGroupId,
                     @Nullable
                     CoLocationConstraint coLocationConstraint)

Method Detail

getJobVertexId

public JobVertexID getJobVertexId()

getSubtaskIndex

public int getSubtaskIndex()

getSlotSharingGroupId

public SlotSharingGroupId getSlotSharingGroupId()

getCoLocationConstraint

@Nullable
public CoLocationConstraint getCoLocationConstraint()

toString

public String toString()

Overrides:

toString in class Object