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

Class DeclarativeSlotPoolBridgeServiceFactory

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.AbstractSlotPoolServiceFactory

org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridgeServiceFactory

All Implemented Interfaces:

SlotPoolServiceFactory

public class DeclarativeSlotPoolBridgeServiceFactory
extends AbstractSlotPoolServiceFactory

Factory for DeclarativeSlotPoolBridge.

Field Summary

Fields inherited from class org.apache.flink.runtime.jobmaster.slotpool.AbstractSlotPoolServiceFactory

batchSlotTimeout, clock, rpcTimeout, slotBatchAllocatable, slotIdleTimeout, slotRequestMaxInterval

Constructor Summary

Constructors

Constructor	Description
DeclarativeSlotPoolBridgeServiceFactory(Clock clock, Duration rpcTimeout, Duration slotIdleTimeout, Duration batchSlotTimeout, Duration slotRequestMaxInterval, boolean slotBatchAllocatable, RequestSlotMatchingStrategy requestSlotMatchingStrategy)

Method Summary

Modifier and Type	Method	Description
SlotPoolService	createSlotPoolService(JobID jobId, DeclarativeSlotPoolFactory declarativeSlotPoolFactory, ComponentMainThreadExecutor componentMainThreadExecutor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DeclarativeSlotPoolBridgeServiceFactory

public DeclarativeSlotPoolBridgeServiceFactory(@Nonnull
                                               Clock clock,
                                               @Nonnull
                                               Duration rpcTimeout,
                                               @Nonnull
                                               Duration slotIdleTimeout,
                                               @Nonnull
                                               Duration batchSlotTimeout,
                                               @Nonnull
                                               Duration slotRequestMaxInterval,
                                               boolean slotBatchAllocatable,
                                               @Nonnull
                                               RequestSlotMatchingStrategy requestSlotMatchingStrategy)

Method Detail

createSlotPoolService

@Nonnull
public SlotPoolService createSlotPoolService(@Nonnull
                                             JobID jobId,
                                             DeclarativeSlotPoolFactory declarativeSlotPoolFactory,
                                             @Nonnull
                                             ComponentMainThreadExecutor componentMainThreadExecutor)