Uses of Interface
org.apache.flink.runtime.jobmaster.slotpool.RequestSlotMatchingStrategy

Packages that use RequestSlotMatchingStrategy

Package	Description
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.slotpool

Uses of RequestSlotMatchingStrategy in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster that return RequestSlotMatchingStrategy

Modifier and Type	Method	Description
static RequestSlotMatchingStrategy	DefaultSlotPoolServiceSchedulerFactory.getRequestSlotMatchingStrategy(org.apache.flink.configuration.Configuration configuration, JobType jobType)

Uses of RequestSlotMatchingStrategy in org.apache.flink.runtime.jobmaster.slotpool

Classes in org.apache.flink.runtime.jobmaster.slotpool that implement RequestSlotMatchingStrategy

Modifier and Type	Class	Description
class	PreferredAllocationRequestSlotMatchingStrategy	RequestSlotMatchingStrategy that takes the preferred allocations into account.
class	SimpleRequestSlotMatchingStrategy	Simple implementation of the RequestSlotMatchingStrategy that matches the pending requests in order as long as the resource profile can be fulfilled.
class	TasksBalancedRequestSlotMatchingStrategy	The tasks balanced based implementation of RequestSlotMatchingStrategy that matches the pending requests for tasks balance at task-manager level.

Methods in org.apache.flink.runtime.jobmaster.slotpool that return RequestSlotMatchingStrategy

Modifier and Type	Method	Description
static RequestSlotMatchingStrategy	PreferredAllocationRequestSlotMatchingStrategy.create(RequestSlotMatchingStrategy rollbackStrategy)

Methods in org.apache.flink.runtime.jobmaster.slotpool with parameters of type RequestSlotMatchingStrategy

Modifier and Type	Method	Description
static RequestSlotMatchingStrategy	PreferredAllocationRequestSlotMatchingStrategy.create(RequestSlotMatchingStrategy rollbackStrategy)

Constructors in org.apache.flink.runtime.jobmaster.slotpool with parameters of type RequestSlotMatchingStrategy

Constructor	Description
DeclarativeSlotPoolBridge(org.apache.flink.api.common.JobID jobId, DeclarativeSlotPoolFactory declarativeSlotPoolFactory, org.apache.flink.util.clock.Clock clock, Duration rpcTimeout, Duration idleSlotTimeout, Duration batchSlotTimeout, RequestSlotMatchingStrategy requestSlotMatchingStrategy, Duration slotRequestMaxInterval, boolean deferSlotAllocation, org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor componentMainThreadExecutor)
DeclarativeSlotPoolBridgeServiceFactory(org.apache.flink.util.clock.Clock clock, Duration rpcTimeout, Duration slotIdleTimeout, Duration batchSlotTimeout, Duration slotRequestMaxInterval, boolean deferSlotAllocation, RequestSlotMatchingStrategy requestSlotMatchingStrategy)