public class MemoryMonitorInfo extends Object implements Serializable
Constructor and Description |
---|
MemoryMonitorInfo() |
MemoryMonitorInfo(boolean isLlap,
int executorsPerNode,
int maxExecutorsOverSubscribeMemory,
double memoryOverSubscriptionFactor,
long noConditionalTaskSize,
long adjustedNoConditionalTaskSize,
long memoryCheckInterval,
double hashTableInflationFactor) |
MemoryMonitorInfo(MemoryMonitorInfo memoryMonitorInfo) |
Modifier and Type | Method and Description |
---|---|
boolean |
doMemoryMonitoring() |
long |
getAdjustedNoConditionalTaskSize() |
long |
getEffectiveThreshold(long maxMemoryPerExecutor) |
int |
getExecutorsPerNode() |
double |
getHashTableInflationFactor() |
int |
getMaxExecutorsOverSubscribeMemory() |
long |
getMemoryCheckInterval() |
double |
getMemoryOverSubscriptionFactor() |
long |
getNoConditionalTaskSize() |
long |
getThreshold() |
boolean |
isLlap() |
void |
setAdjustedNoConditionalTaskSize(long adjustedNoConditionalTaskSize) |
void |
setExecutorsPerNode(int executorsPerNode) |
void |
setHashTableInflationFactor(double hashTableInflationFactor) |
void |
setLlap(boolean llap) |
void |
setMaxExecutorsOverSubscribeMemory(int maxExecutorsOverSubscribeMemory) |
void |
setMemoryCheckInterval(long memoryCheckInterval) |
void |
setMemoryOverSubscriptionFactor(double memoryOverSubscriptionFactor) |
void |
setNoConditionalTaskSize(long noConditionalTaskSize) |
String |
toString() |
public MemoryMonitorInfo()
public MemoryMonitorInfo(boolean isLlap, int executorsPerNode, int maxExecutorsOverSubscribeMemory, double memoryOverSubscriptionFactor, long noConditionalTaskSize, long adjustedNoConditionalTaskSize, long memoryCheckInterval, double hashTableInflationFactor)
public MemoryMonitorInfo(MemoryMonitorInfo memoryMonitorInfo)
public int getExecutorsPerNode()
public void setExecutorsPerNode(int executorsPerNode)
public int getMaxExecutorsOverSubscribeMemory()
public void setMaxExecutorsOverSubscribeMemory(int maxExecutorsOverSubscribeMemory)
public double getMemoryOverSubscriptionFactor()
public void setMemoryOverSubscriptionFactor(double memoryOverSubscriptionFactor)
public long getNoConditionalTaskSize()
public void setNoConditionalTaskSize(long noConditionalTaskSize)
public long getAdjustedNoConditionalTaskSize()
public void setAdjustedNoConditionalTaskSize(long adjustedNoConditionalTaskSize)
public long getMemoryCheckInterval()
public void setMemoryCheckInterval(long memoryCheckInterval)
public double getHashTableInflationFactor()
public void setHashTableInflationFactor(double hashTableInflationFactor)
public long getThreshold()
public void setLlap(boolean llap)
public boolean isLlap()
public boolean doMemoryMonitoring()
public long getEffectiveThreshold(long maxMemoryPerExecutor)
Copyright © 2022 The Apache Software Foundation. All rights reserved.