Package | Description |
---|---|
org.apache.flink.runtime.clusterframework.types | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Method and Description |
---|---|
static SlotProfile |
SlotProfile.noLocality(ResourceProfile resourceProfile)
Returns a slot profile for the given resource profile, without any locality requirements.
|
static SlotProfile |
SlotProfile.noRequirements()
Returns a slot profile that has no requirements.
|
static SlotProfile |
SlotProfile.preferredLocality(ResourceProfile resourceProfile,
Collection<TaskManagerLocation> preferredLocations)
Returns a slot profile for the given resource profile and the preferred locations.
|
static SlotProfile |
SlotProfile.priorAllocation(ResourceProfile taskResourceProfile,
ResourceProfile physicalSlotResourceProfile,
Collection<TaskManagerLocation> preferredLocations,
Collection<AllocationID> priorAllocations,
Set<AllocationID> previousExecutionGraphAllocations)
Returns a slot profile for the given resource profile, prior allocations and all prior
allocation ids from the whole execution graph.
|
Modifier and Type | Method and Description |
---|---|
abstract CompletableFuture<LogicalSlot> |
SlotProviderStrategy.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile)
Allocating slot with specific requirement.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.