Package org.apache.flink.runtime.clusterframework

Class TaskExecutorProcessUtils

java.lang.Object

org.apache.flink.runtime.clusterframework.TaskExecutorProcessUtils

public class TaskExecutorProcessUtils
extends Object

Utility class for TaskExecutor memory configurations.

See TaskExecutorProcessSpec for details about memory components of TaskExecutor and their relationships.

Method Summary

Modifier and Type	Method	Description
static String	generateDynamicConfigsStr(TaskExecutorProcessSpec taskExecutorProcessSpec)
static CPUResource	getCpuCoresWithFallback(Configuration config, double fallback)
static double	getCpuCoresWithFallbackConfigOption(Configuration config, ConfigOption<Double> fallbackOption)
static TaskExecutorProcessSpecBuilder	newProcessSpecBuilder(Configuration config)
static TaskExecutorProcessSpec	processSpecFromConfig(Configuration config)
static TaskExecutorProcessSpec	processSpecFromWorkerResourceSpec(Configuration config, WorkerResourceSpec workerResourceSpec)

Methods inherited from class java.lang.Object

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

Method Detail

generateDynamicConfigsStr

public static String generateDynamicConfigsStr(TaskExecutorProcessSpec taskExecutorProcessSpec)

newProcessSpecBuilder

public static TaskExecutorProcessSpecBuilder newProcessSpecBuilder(Configuration config)

processSpecFromConfig

public static TaskExecutorProcessSpec processSpecFromConfig(Configuration config)

processSpecFromWorkerResourceSpec

public static TaskExecutorProcessSpec processSpecFromWorkerResourceSpec(Configuration config,
                                                                        WorkerResourceSpec workerResourceSpec)

getCpuCoresWithFallbackConfigOption

public static double getCpuCoresWithFallbackConfigOption(Configuration config,
                                                         ConfigOption<Double> fallbackOption)

getCpuCoresWithFallback

public static CPUResource getCpuCoresWithFallback(Configuration config,
                                                  double fallback)