Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.slots |
Modifier and Type | Method and Description |
---|---|
AllocatedSlot |
Slot.getAllocatedSlot()
Gets the allocated slot that this slot refers to.
|
Modifier and Type | Method and Description |
---|---|
Future<Boolean> |
SlotPoolGateway.offerSlot(AllocatedSlot slot) |
boolean |
SlotPool.offerSlot(AllocatedSlot slot)
Slot offering by TaskManager with AllocationID.
|
Modifier and Type | Method and Description |
---|---|
Future<Iterable<SlotOffer>> |
SlotPoolGateway.offerSlots(Iterable<Tuple2<AllocatedSlot,SlotOffer>> offers) |
Iterable<SlotOffer> |
SlotPool.offerSlots(Iterable<Tuple2<AllocatedSlot,SlotOffer>> offers) |
Constructor and Description |
---|
SharedSlot(AllocatedSlot allocatedSlot,
SlotOwner owner,
SlotSharingGroupAssignment assignmentGroup)
Creates a new shared slot that has no parent (is a root slot) and does not belong to any task group.
|
SimpleSlot(AllocatedSlot allocatedSlot,
SlotOwner owner,
int slotNumber)
Creates a new simple slot that stands alone and does not belong to shared slot.
|
Slot(AllocatedSlot allocatedSlot,
SlotOwner owner,
int slotNumber,
SharedSlot parent,
AbstractID groupID)
Base constructor for slots.
|
Modifier and Type | Method and Description |
---|---|
AllocatedSlot |
SlotAndLocality.slot() |
Constructor and Description |
---|
SlotAndLocality(AllocatedSlot slot,
Locality locality) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.