public class TaskManagerConfiguration extends Object implements TaskManagerRuntimeInfo
TaskExecutor
.Constructor and Description |
---|
TaskManagerConfiguration(int numberSlots,
String[] tmpDirectories,
Time timeout,
Time maxRegistrationDuration,
Time initialRegistrationPause,
Time maxRegistrationPause,
Time refusedRegistrationPause,
long cleanupInterval,
Configuration configuration,
boolean exitJvmOnOutOfMemory) |
Modifier and Type | Method and Description |
---|---|
static TaskManagerConfiguration |
fromConfiguration(Configuration configuration) |
long |
getCleanupInterval() |
Configuration |
getConfiguration()
Gets the configuration that the TaskManager was started with.
|
Time |
getInitialRegistrationPause() |
Time |
getMaxRegistrationDuration() |
Time |
getMaxRegistrationPause() |
int |
getNumberSlots() |
Time |
getRefusedRegistrationPause() |
Time |
getTimeout() |
String[] |
getTmpDirectories()
Gets the list of temporary file directories.
|
boolean |
shouldExitJvmOnOutOfMemoryError()
Checks whether the TaskManager should exit the JVM when the task thread throws
an OutOfMemoryError.
|
public TaskManagerConfiguration(int numberSlots, String[] tmpDirectories, Time timeout, Time maxRegistrationDuration, Time initialRegistrationPause, Time maxRegistrationPause, Time refusedRegistrationPause, long cleanupInterval, Configuration configuration, boolean exitJvmOnOutOfMemory)
public int getNumberSlots()
public Time getTimeout()
public Time getMaxRegistrationDuration()
public Time getInitialRegistrationPause()
public Time getMaxRegistrationPause()
public Time getRefusedRegistrationPause()
public long getCleanupInterval()
public Configuration getConfiguration()
TaskManagerRuntimeInfo
getConfiguration
in interface TaskManagerRuntimeInfo
public String[] getTmpDirectories()
TaskManagerRuntimeInfo
getTmpDirectories
in interface TaskManagerRuntimeInfo
public boolean shouldExitJvmOnOutOfMemoryError()
TaskManagerRuntimeInfo
shouldExitJvmOnOutOfMemoryError
in interface TaskManagerRuntimeInfo
public static TaskManagerConfiguration fromConfiguration(Configuration configuration)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.