public class TaskExecutorProcessUtils extends Object
See TaskExecutorProcessSpec
for details about memory components of TaskExecutor and their relationships.
public static String generateJvmParametersStr(TaskExecutorProcessSpec taskExecutorProcessSpec)
public static String generateDynamicConfigsStr(TaskExecutorProcessSpec taskExecutorProcessSpec)
public static List<ResourceProfile> createDefaultWorkerSlotProfiles(TaskExecutorProcessSpec taskExecutorProcessSpec, int numberOfSlots)
public static ResourceProfile generateDefaultSlotResourceProfile(TaskExecutorProcessSpec taskExecutorProcessSpec, int numberOfSlots)
public static ResourceProfile generateTotalAvailableResourceProfile(TaskExecutorProcessSpec taskExecutorProcessSpec)
public static TaskExecutorProcessSpecBuilder newProcessSpecBuilder(Configuration config)
public static TaskExecutorProcessSpec processSpecFromConfig(Configuration config)
public static boolean isTaskExecutorProcessResourceExplicitlyConfigured(Configuration config)
public static boolean isManagedMemorySizeExplicitlyConfigured(Configuration config)
public static boolean isNetworkMemoryExplicitlyConfigured(Configuration config)
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–2020 The Apache Software Foundation. All rights reserved.