public class SlotManagerConfiguration extends Object
SlotManager
.Constructor and Description |
---|
SlotManagerConfiguration(Time taskManagerRequestTimeout,
Time slotRequestTimeout,
Time taskManagerTimeout,
boolean waitResultConsumedBeforeRelease,
SlotMatchingStrategy slotMatchingStrategy,
WorkerResourceSpec defaultWorkerResourceSpec,
int numSlotsPerWorker,
int maxSlotNum,
int redundantTaskManagerNum) |
Modifier and Type | Method and Description |
---|---|
static SlotManagerConfiguration |
fromConfiguration(Configuration configuration,
WorkerResourceSpec defaultWorkerResourceSpec) |
WorkerResourceSpec |
getDefaultWorkerResourceSpec() |
int |
getMaxSlotNum() |
int |
getNumSlotsPerWorker() |
int |
getRedundantTaskManagerNum() |
SlotMatchingStrategy |
getSlotMatchingStrategy() |
Time |
getSlotRequestTimeout() |
Time |
getTaskManagerRequestTimeout() |
Time |
getTaskManagerTimeout() |
boolean |
isWaitResultConsumedBeforeRelease() |
public SlotManagerConfiguration(Time taskManagerRequestTimeout, Time slotRequestTimeout, Time taskManagerTimeout, boolean waitResultConsumedBeforeRelease, SlotMatchingStrategy slotMatchingStrategy, WorkerResourceSpec defaultWorkerResourceSpec, int numSlotsPerWorker, int maxSlotNum, int redundantTaskManagerNum)
public Time getTaskManagerRequestTimeout()
public Time getSlotRequestTimeout()
public Time getTaskManagerTimeout()
public boolean isWaitResultConsumedBeforeRelease()
public SlotMatchingStrategy getSlotMatchingStrategy()
public WorkerResourceSpec getDefaultWorkerResourceSpec()
public int getNumSlotsPerWorker()
public int getMaxSlotNum()
public int getRedundantTaskManagerNum()
public static SlotManagerConfiguration fromConfiguration(Configuration configuration, WorkerResourceSpec defaultWorkerResourceSpec) throws ConfigurationException
ConfigurationException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.