public class TaskExecutorMemoryConfiguration extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_FRAMEWORK_HEAP |
static String |
FIELD_NAME_FRAMEWORK_OFFHEAP |
static String |
FIELD_NAME_JVM_METASPACE |
static String |
FIELD_NAME_JVM_OVERHEAD |
static String |
FIELD_NAME_MANAGED_MEMORY |
static String |
FIELD_NAME_NETWORK_MEMORY |
static String |
FIELD_NAME_TASK_HEAP |
static String |
FIELD_NAME_TASK_OFFHEAP |
static String |
FIELD_NAME_TOTAL_FLINK_MEMORY |
static String |
FIELD_NAME_TOTAL_PROCESS_MEMORY |
Constructor and Description |
---|
TaskExecutorMemoryConfiguration(Long frameworkHeap,
Long taskHeap,
Long frameworkOffHeap,
Long taskOffHeap,
Long networkMemory,
Long managedMemoryTotal,
Long jvmMetaspace,
Long jvmOverhead,
Long totalFlinkMemory,
Long totalProcessMemory) |
Modifier and Type | Method and Description |
---|---|
static TaskExecutorMemoryConfiguration |
create(Configuration config)
Factory method for initializing a TaskExecutorMemoryConfiguration based on the passed
Configuration.
|
boolean |
equals(Object o) |
Long |
getFrameworkHeap()
Returns the configured heap size used by the framework.
|
Long |
getFrameworkOffHeap()
Returns the configured off-heap size used by the framework.
|
Long |
getJvmMetaspace()
Returns the maximum Metaspace size allowed for the task manager.
|
Long |
getJvmOverhead()
Returns the threshold for defining the maximum amount of memory used for the JVM overhead.
|
Long |
getManagedMemoryTotal()
Returns the total amount of memory reserved for by the MemoryManager.
|
Long |
getNetworkMemory()
Returns the configured maximum network memory.
|
Long |
getTaskHeap()
Returns the configured heap size used by the tasks.
|
Long |
getTaskOffHeap()
Returns the configured off-heap size used by the tasks.
|
Long |
getTotalFlinkMemory()
Returns the amount of memory configured to be used by Flink excluding things like JVM
Metaspace and other JVM overhead.
|
Long |
getTotalProcessMemory()
Returns the total amount of memory configured to be used by the JVM including all the
different memory pools.
|
int |
hashCode() |
String |
toString() |
public static final String FIELD_NAME_FRAMEWORK_HEAP
public static final String FIELD_NAME_TASK_HEAP
public static final String FIELD_NAME_FRAMEWORK_OFFHEAP
public static final String FIELD_NAME_TASK_OFFHEAP
public static final String FIELD_NAME_NETWORK_MEMORY
public static final String FIELD_NAME_MANAGED_MEMORY
public static final String FIELD_NAME_JVM_METASPACE
public static final String FIELD_NAME_JVM_OVERHEAD
public static final String FIELD_NAME_TOTAL_FLINK_MEMORY
public static final String FIELD_NAME_TOTAL_PROCESS_MEMORY
public static TaskExecutorMemoryConfiguration create(Configuration config)
config
- The Configuration used for initializing the TaskExecutorMemoryConfiguration.public Long getFrameworkHeap()
public Long getTaskHeap()
public Long getFrameworkOffHeap()
public Long getTaskOffHeap()
public Long getNetworkMemory()
public Long getManagedMemoryTotal()
public Long getJvmMetaspace()
public Long getJvmOverhead()
public Long getTotalFlinkMemory()
public Long getTotalProcessMemory()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.