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 and Description
DeclarativeSlotPoolServiceFactory(Clock clock, Time idleSlotTimeout, Time rpcTimeout)

Method Summary

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

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,
                                         Time idleSlotTimeout,
                                         Time rpcTimeout)

Method Detail

createSlotPoolService

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

Specified by:

createSlotPoolService in interface SlotPoolServiceFactory