Package | Description |
---|---|
org.apache.flink.runtime.instance |
Modifier and Type | Method and Description |
---|---|
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
CoLocationConstraint constraint) |
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
JobVertexID groupId) |
SimpleSlot |
Instance.allocateSimpleSlot()
Allocates a simple slot on this TaskManager instance.
|
SimpleSlot |
SlotSharingGroupAssignment.getSlotForTask(CoLocationConstraint constraint,
Iterable<TaskManagerLocation> locationPreferences)
Gets a slot for a task that has a co-location constraint.
|
SimpleSlot |
SlotSharingGroupAssignment.getSlotForTask(JobVertexID vertexID,
Iterable<TaskManagerLocation> locationPreferences)
Gets a slot suitable for the given task vertex.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.