public class ConfigurationUtils extends Object
Configuration
related helper functions.Modifier and Type | Method and Description |
---|---|
static Configuration |
createConfiguration(Properties properties)
Creates a new
Configuration from the given Properties . |
static MemorySize |
getJobManagerHeapMemory(Configuration configuration)
Get job manager's heap memory.
|
static Optional<Time> |
getSystemResourceMetricsProbingInterval(Configuration configuration) |
static MemorySize |
getTaskManagerHeapMemory(Configuration configuration)
Get task manager's heap memory.
|
static String[] |
parseLocalStateDirectories(Configuration configuration)
Extracts the local state directories as defined by
CheckpointingOptions.LOCAL_RECOVERY_TASK_MANAGER_STATE_ROOT_DIRS . |
static String[] |
parseTempDirectories(Configuration configuration)
Extracts the task manager directories for temporary files as defined by
CoreOptions.TMP_DIRS . |
public static MemorySize getJobManagerHeapMemory(Configuration configuration)
JobManagerOptions.JOB_MANAGER_HEAP_MEMORY
and
the old key JobManagerOptions.JOB_MANAGER_HEAP_MEMORY_MB
for backwards compatibility.configuration
- the configuration objectpublic static MemorySize getTaskManagerHeapMemory(Configuration configuration)
TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY
and
the old key TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY_MB
for backwards compatibility.configuration
- the configuration objectpublic static Optional<Time> getSystemResourceMetricsProbingInterval(Configuration configuration)
MetricOptions.SYSTEM_RESOURCE_METRICS_PROBING_INTERVAL
or Optional.empty()
if
MetricOptions.SYSTEM_RESOURCE_METRICS
are disabled.@Nonnull public static String[] parseTempDirectories(Configuration configuration)
CoreOptions.TMP_DIRS
.configuration
- configuration object@Nonnull public static String[] parseLocalStateDirectories(Configuration configuration)
CheckpointingOptions.LOCAL_RECOVERY_TASK_MANAGER_STATE_ROOT_DIRS
.configuration
- configuration object@Nonnull public static Configuration createConfiguration(Properties properties)
Configuration
from the given Properties
.properties
- to convert into a Configuration
Configuration
which has been populated by the values of the given Properties
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.