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 org.apache.flink.api.common.time.Time	batchSlotTimeout
protected org.apache.flink.util.clock.Clock	clock
protected org.apache.flink.api.common.time.Time	rpcTimeout
protected org.apache.flink.api.common.time.Time	slotIdleTimeout

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractSlotPoolServiceFactory(org.apache.flink.util.clock.Clock clock, org.apache.flink.api.common.time.Time rpcTimeout, org.apache.flink.api.common.time.Time slotIdleTimeout, org.apache.flink.api.common.time.Time batchSlotTimeout)

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 org.apache.flink.util.clock.Clock clock

rpcTimeout

@Nonnull
protected final org.apache.flink.api.common.time.Time rpcTimeout

slotIdleTimeout

@Nonnull
protected final org.apache.flink.api.common.time.Time slotIdleTimeout

batchSlotTimeout

@Nonnull
protected final org.apache.flink.api.common.time.Time batchSlotTimeout

Constructor Detail

AbstractSlotPoolServiceFactory

protected AbstractSlotPoolServiceFactory(@Nonnull
                                         org.apache.flink.util.clock.Clock clock,
                                         @Nonnull
                                         org.apache.flink.api.common.time.Time rpcTimeout,
                                         @Nonnull
                                         org.apache.flink.api.common.time.Time slotIdleTimeout,
                                         @Nonnull
                                         org.apache.flink.api.common.time.Time batchSlotTimeout)