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, slotIdleTimeout

Constructor Summary

Constructors

Constructor and Description
DeclarativeSlotPoolBridgeServiceFactory(Clock clock, Time rpcTimeout, Time slotIdleTimeout, Time batchSlotTimeout, RequestSlotMatchingStrategy requestSlotMatchingStrategy)

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

DeclarativeSlotPoolBridgeServiceFactory

public DeclarativeSlotPoolBridgeServiceFactory(@Nonnull
                                               Clock clock,
                                               @Nonnull
                                               Time rpcTimeout,
                                               @Nonnull
                                               Time slotIdleTimeout,
                                               @Nonnull
                                               Time batchSlotTimeout,
                                               @Nonnull
                                               RequestSlotMatchingStrategy requestSlotMatchingStrategy)

Method Detail

createSlotPoolService

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