public class TaskExecutorProcessUtils extends Object
See TaskExecutorProcessSpec
for details about memory components of TaskExecutor and
their relationships.
Modifier and Type | Method and Description |
---|---|
static String |
generateDynamicConfigsStr(TaskExecutorProcessSpec taskExecutorProcessSpec) |
static Configuration |
getConfigurationMapLegacyTaskManagerHeapSizeToConfigOption(Configuration configuration,
ConfigOption<MemorySize> configOption) |
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) |
public static String generateDynamicConfigsStr(TaskExecutorProcessSpec taskExecutorProcessSpec)
public static TaskExecutorProcessSpecBuilder newProcessSpecBuilder(Configuration config)
public static TaskExecutorProcessSpec processSpecFromConfig(Configuration config)
public static TaskExecutorProcessSpec processSpecFromWorkerResourceSpec(Configuration config, WorkerResourceSpec workerResourceSpec)
public static double getCpuCoresWithFallbackConfigOption(Configuration config, ConfigOption<Double> fallbackOption)
public static CPUResource getCpuCoresWithFallback(Configuration config, double fallback)
public static Configuration getConfigurationMapLegacyTaskManagerHeapSizeToConfigOption(Configuration configuration, ConfigOption<MemorySize> configOption)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.