org.apache.flink.runtime.jobmaster.slotpool

Class DefaultSlotPoolFactory

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.DefaultSlotPoolFactory

All Implemented Interfaces:

SlotPoolFactory

public class DefaultSlotPoolFactory
extends Object
implements SlotPoolFactory

Default slot pool factory.

Constructor Summary

Constructors

Constructor and Description
DefaultSlotPoolFactory(RpcService rpcService, SchedulingStrategy schedulingStrategy, Clock clock, Time rpcTimeout, Time slotIdleTimeout)

Method Summary

Modifier and Type	Method and Description
SlotPool	createSlotPool(JobID jobId)
static DefaultSlotPoolFactory	fromConfiguration(Configuration configuration, RpcService rpcService)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSlotPoolFactory

public DefaultSlotPoolFactory(@Nonnull
                              RpcService rpcService,
                              @Nonnull
                              SchedulingStrategy schedulingStrategy,
                              @Nonnull
                              Clock clock,
                              @Nonnull
                              Time rpcTimeout,
                              @Nonnull
                              Time slotIdleTimeout)

Method Detail

createSlotPool

@Nonnull
public SlotPool createSlotPool(@Nonnull
                                        JobID jobId)

Specified by:

createSlotPool in interface SlotPoolFactory

fromConfiguration

public static DefaultSlotPoolFactory fromConfiguration(@Nonnull
                                                       Configuration configuration,
                                                       @Nonnull
                                                       RpcService rpcService)