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,
CPUResource maxTotalCpu,
MemorySize maxTotalMem,
int redundantTaskManagerNum) |
Modifier and Type | Method and Description |
---|---|
static SlotManagerConfiguration |
fromConfiguration(Configuration configuration,
WorkerResourceSpec defaultWorkerResourceSpec) |
WorkerResourceSpec |
getDefaultWorkerResourceSpec() |
int |
getMaxSlotNum() |
CPUResource |
getMaxTotalCpu() |
MemorySize |
getMaxTotalMem() |
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, CPUResource maxTotalCpu, MemorySize maxTotalMem, 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 CPUResource getMaxTotalCpu()
public MemorySize getMaxTotalMem()
public int getRedundantTaskManagerNum()
public static SlotManagerConfiguration fromConfiguration(Configuration configuration, WorkerResourceSpec defaultWorkerResourceSpec) throws ConfigurationException
ConfigurationException
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.