Package org.apache.flink.runtime.util.config.memory.taskmanager

Class TaskExecutorFlinkMemoryUtils

java.lang.Object

org.apache.flink.runtime.util.config.memory.taskmanager.TaskExecutorFlinkMemoryUtils

All Implemented Interfaces:

FlinkMemoryUtils<TaskExecutorFlinkMemory>

public class TaskExecutorFlinkMemoryUtils
extends Object
implements FlinkMemoryUtils<TaskExecutorFlinkMemory>

FlinkMemoryUtils for Task Executor.

The required fine-grained components are TaskManagerOptions.TASK_HEAP_MEMORY and TaskManagerOptions.MANAGED_MEMORY_SIZE.

Constructor Summary

Constructors

Constructor	Description
TaskExecutorFlinkMemoryUtils()

Method Summary

Modifier and Type	Method	Description
TaskExecutorFlinkMemory	deriveFromRequiredFineGrainedOptions(Configuration config)
TaskExecutorFlinkMemory	deriveFromTotalFlinkMemory(Configuration config, MemorySize totalFlinkMemorySize)
static MemorySize	getFrameworkHeapMemorySize(Configuration config)
static MemorySize	getFrameworkOffHeapMemorySize(Configuration config)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutorFlinkMemoryUtils

public TaskExecutorFlinkMemoryUtils()

Method Detail

deriveFromRequiredFineGrainedOptions

public TaskExecutorFlinkMemory deriveFromRequiredFineGrainedOptions(Configuration config)

Specified by:

deriveFromRequiredFineGrainedOptions in interface FlinkMemoryUtils<TaskExecutorFlinkMemory>

deriveFromTotalFlinkMemory

public TaskExecutorFlinkMemory deriveFromTotalFlinkMemory(Configuration config,
                                                          MemorySize totalFlinkMemorySize)

Specified by:

deriveFromTotalFlinkMemory in interface FlinkMemoryUtils<TaskExecutorFlinkMemory>

getFrameworkHeapMemorySize

public static MemorySize getFrameworkHeapMemorySize(Configuration config)

getFrameworkOffHeapMemorySize

public static MemorySize getFrameworkOffHeapMemorySize(Configuration config)