Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Method and Description |
---|---|
abstract CompletableFuture<LogicalSlot> |
SlotProviderStrategy.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile)
Allocating slot with specific requirement.
|
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<LogicalSlot> |
SlotProvider.allocateBatchSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile)
Allocating batch slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SchedulerImpl.allocateBatchSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile) |
default CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
ThrowingSlotProvider.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout) |
CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SchedulerImpl.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.