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

Class AbstractSlotPoolServiceFactory

java.lang.Object

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

All Implemented Interfaces:

SlotPoolServiceFactory

Direct Known Subclasses:

DeclarativeSlotPoolBridgeServiceFactory

public abstract class AbstractSlotPoolServiceFactory
extends Object
implements SlotPoolServiceFactory

Abstract SlotPoolServiceFactory.

Field Summary

Fields

Modifier and Type	Field	Description
protected Duration	batchSlotTimeout
protected Clock	clock
protected Duration	rpcTimeout
protected boolean	slotBatchAllocatable
protected Duration	slotIdleTimeout
protected Duration	slotRequestMaxInterval

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractSlotPoolServiceFactory(Clock clock, Duration rpcTimeout, Duration slotIdleTimeout, Duration batchSlotTimeout, Duration slotRequestMaxInterval, boolean slotBatchAllocatable)

Method Summary

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.jobmaster.slotpool.SlotPoolServiceFactory

createSlotPoolService

Field Detail

clock

@Nonnull
protected final Clock clock

rpcTimeout

@Nonnull
protected final Duration rpcTimeout

slotIdleTimeout

@Nonnull
protected final Duration slotIdleTimeout

batchSlotTimeout

@Nonnull
protected final Duration batchSlotTimeout

slotRequestMaxInterval

@Nonnull
protected final Duration slotRequestMaxInterval

slotBatchAllocatable

protected final boolean slotBatchAllocatable

Constructor Detail

AbstractSlotPoolServiceFactory

protected AbstractSlotPoolServiceFactory(@Nonnull
                                         Clock clock,
                                         @Nonnull
                                         Duration rpcTimeout,
                                         @Nonnull
                                         Duration slotIdleTimeout,
                                         @Nonnull
                                         Duration batchSlotTimeout,
                                         @Nonnull
                                         Duration slotRequestMaxInterval,
                                         boolean slotBatchAllocatable)