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

Class DeclarativeSlotPoolServiceFactory

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolServiceFactory

All Implemented Interfaces:

SlotPoolServiceFactory

public class DeclarativeSlotPoolServiceFactory
extends Object
implements SlotPoolServiceFactory

Factory for the DeclarativeSlotPoolService.

Constructor Summary

Constructors

Constructor	Description
DeclarativeSlotPoolServiceFactory(Clock clock, Duration idleSlotTimeout, Duration rpcTimeout, Duration slotRequestMaxInterval)

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

DeclarativeSlotPoolServiceFactory

public DeclarativeSlotPoolServiceFactory(Clock clock,
                                         Duration idleSlotTimeout,
                                         Duration rpcTimeout,
                                         @Nonnull
                                         Duration slotRequestMaxInterval)

Method Detail

createSlotPoolService

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

Specified by:

createSlotPoolService in interface SlotPoolServiceFactory