public class ScheduledUnit extends Object
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) |
Modifier and Type | Method and Description |
---|---|
CoLocationConstraint |
getCoLocationConstraint() |
JobVertexID |
getJobVertexId() |
SlotSharingGroupId |
getSlotSharingGroupId() |
int |
getSubtaskIndex() |
String |
toString() |
@VisibleForTesting public ScheduledUnit(Execution task)
public ScheduledUnit(Execution task, @Nullable SlotSharingGroupId slotSharingGroupId)
public ScheduledUnit(Execution task, @Nullable SlotSharingGroupId slotSharingGroupId, @Nullable CoLocationConstraint coLocationConstraint)
@VisibleForTesting public ScheduledUnit(JobVertexID jobVertexId, @Nullable SlotSharingGroupId slotSharingGroupId, @Nullable CoLocationConstraint coLocationConstraint)
public ScheduledUnit(ExecutionVertexID executionVertexId, @Nullable SlotSharingGroupId slotSharingGroupId, @Nullable CoLocationConstraint coLocationConstraint)
public JobVertexID getJobVertexId()
public int getSubtaskIndex()
@Nullable public SlotSharingGroupId getSlotSharingGroupId()
@Nullable public CoLocationConstraint getCoLocationConstraint()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.