Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.scheduler |
Modifier and Type | Method and Description |
---|---|
CoLocationConstraint |
ExecutionVertex.getLocationConstraint() |
Modifier and Type | Method and Description |
---|---|
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
CoLocationConstraint constraint) |
SimpleSlot |
SlotSharingGroupAssignment.getSlotForTask(CoLocationConstraint constraint,
Iterable<TaskManagerLocation> locationPreferences)
Gets a slot for a task that has a co-location constraint.
|
Modifier and Type | Method and Description |
---|---|
CoLocationConstraint |
ScheduledUnit.getCoLocationConstraint() |
CoLocationConstraint |
CoLocationGroup.getLocationConstraint(int subtask) |
Modifier and Type | Method and Description |
---|---|
protected SimpleSlot |
Scheduler.getNewSlotForSharingGroup(ExecutionVertex vertex,
Iterable<TaskManagerLocation> requestedLocations,
SlotSharingGroupAssignment groupAssignment,
CoLocationConstraint constraint,
boolean localOnly)
Tries to allocate a new slot for a vertex that is part of a slot sharing group.
|
Constructor and Description |
---|
ScheduledUnit(Execution task,
JobVertexID jobVertexId,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
ScheduledUnit(JobVertexID jobVertexId,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.