Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.scheduler | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Method and Description |
---|---|
Locality |
SharedSlot.getLocality() |
Locality |
SimpleSlot.getLocality()
Gets the locality information attached to this slot.
|
Modifier and Type | Method and Description |
---|---|
Tuple2<SharedSlot,Locality> |
SlotSharingGroupAssignment.getSharedSlotForTask(AbstractID groupId,
Iterable<TaskManagerLocation> preferredLocations,
boolean localOnly) |
Modifier and Type | Method and Description |
---|---|
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
CoLocationConstraint constraint) |
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
JobVertexID groupId) |
void |
SimpleSlot.setLocality(Locality locality)
Attached locality information to this slot.
|
Modifier and Type | Method and Description |
---|---|
static Locality |
Locality.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Locality[] |
Locality.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Locality |
LogicalSlot.getLocality()
Gets the locality of this slot.
|
Modifier and Type | Method and Description |
---|---|
Locality |
SingleLogicalSlot.getLocality() |
Locality |
SlotAndLocality.getLocality() |
Modifier and Type | Method and Description |
---|---|
<IN,OUT> OUT |
SchedulingStrategy.findMatchWithLocality(SlotProfile slotProfile,
java.util.stream.Stream<IN> candidates,
java.util.function.Function<IN,SlotContext> contextExtractor,
java.util.function.Predicate<IN> additionalRequirementsFilter,
java.util.function.BiFunction<IN,Locality,OUT> resultProducer)
This method takes the candidate slots, extracts slot contexts from them, filters them by the profile
requirements and potentially by additional requirements, and produces a result from a match.
|
<IN,OUT> OUT |
PreviousAllocationSchedulingStrategy.findMatchWithLocality(SlotProfile slotProfile,
java.util.stream.Stream<IN> candidates,
java.util.function.Function<IN,SlotContext> contextExtractor,
java.util.function.Predicate<IN> additionalRequirementsFilter,
java.util.function.BiFunction<IN,Locality,OUT> resultProducer) |
<IN,OUT> OUT |
LocationPreferenceSchedulingStrategy.findMatchWithLocality(SlotProfile slotProfile,
java.util.stream.Stream<IN> candidates,
java.util.function.Function<IN,SlotContext> contextExtractor,
java.util.function.Predicate<IN> additionalRequirementsFilter,
java.util.function.BiFunction<IN,Locality,OUT> resultProducer) |
Constructor and Description |
---|
SingleLogicalSlot(SlotRequestId slotRequestId,
SlotContext slotContext,
SlotSharingGroupId slotSharingGroupId,
Locality locality,
SlotOwner slotOwner) |
SlotAndLocality(org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlot slot,
Locality locality) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.