Package | Description |
---|---|
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Method and Description |
---|---|
PhysicalSlot |
SlotAndLocality.getSlot() |
Modifier and Type | Method and Description |
---|---|
Optional<PhysicalSlot> |
SlotPoolImpl.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID) |
Optional<PhysicalSlot> |
SlotPool.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID)
Allocates the available slot with the given allocation id under the given request id.
|
CompletableFuture<PhysicalSlot> |
SlotPoolImpl.requestNewAllocatedBatchSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile) |
CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedBatchSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile)
Requests the allocation of a new batch slot from the resource manager.
|
CompletableFuture<PhysicalSlot> |
SlotPoolImpl.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Time timeout) |
CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Time timeout)
Request the allocation of a new slot from the resource manager.
|
Constructor and Description |
---|
SlotAndLocality(PhysicalSlot slot,
Locality locality) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.