Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Class and Description |
---|---|
class |
SimpleSlotContext
Simple implementation of the
SlotContext interface for the legacy code. |
Modifier and Type | Interface and Description |
---|---|
interface |
SlotContext
Interface for the context of a
LogicalSlot . |
Modifier and Type | Method and Description |
---|---|
protected <IN,OUT> OUT |
LocationPreferenceSchedulingStrategy.doFindMatchWithLocality(SlotProfile slotProfile,
java.util.stream.Stream<IN> candidates,
java.util.function.Function<IN,SlotInfo> contextExtractor,
java.util.function.Predicate<IN> additionalRequirementsFilter,
java.util.function.BiFunction<IN,Locality,OUT> resultProducer) |
<IN,OUT> OUT |
SchedulingStrategy.findMatchWithLocality(SlotProfile slotProfile,
java.util.function.Supplier<java.util.stream.Stream<IN>> candidates,
java.util.function.Function<IN,SlotInfo> 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.function.Supplier<java.util.stream.Stream<IN>> candidates,
java.util.function.Function<IN,SlotInfo> contextExtractor,
java.util.function.Predicate<IN> additionalRequirementsFilter,
java.util.function.BiFunction<IN,Locality,OUT> resultProducer) |
<IN,OUT> OUT |
LocationPreferenceSchedulingStrategy.findMatchWithLocality(SlotProfile slotProfile,
java.util.function.Supplier<java.util.stream.Stream<IN>> candidates,
java.util.function.Function<IN,SlotInfo> contextExtractor,
java.util.function.Predicate<IN> additionalRequirementsFilter,
java.util.function.BiFunction<IN,Locality,OUT> resultProducer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.