public class TaskManagerServicesConfiguration extends Object
Constructor and Description |
---|
TaskManagerServicesConfiguration(Configuration configuration,
ResourceID resourceID,
InetAddress taskManagerAddress,
boolean localCommunicationOnly,
String[] tmpDirPaths,
String[] localRecoveryStateRootDirectories,
long freeHeapMemoryWithDefrag,
long maxJvmHeapMemory,
boolean localRecoveryEnabled,
QueryableStateConfiguration queryableStateConfig,
int numberOfSlots,
long configuredMemory,
MemoryType memoryType,
boolean preAllocateMemory,
float memoryFraction,
int pageSize,
long timerServiceShutdownTimeout,
RetryingRegistrationConfiguration retryingRegistrationConfiguration,
Optional<Time> systemResourceMetricsProbingInterval) |
Modifier and Type | Method and Description |
---|---|
static TaskManagerServicesConfiguration |
fromConfiguration(Configuration configuration,
ResourceID resourceID,
InetAddress remoteAddress,
long freeHeapMemoryWithDefrag,
long maxJvmHeapMemory,
boolean localCommunicationOnly)
Utility method to extract TaskManager config parameters from the configuration and to
sanity check them.
|
Configuration |
getConfiguration() |
float |
getMemoryFraction() |
int |
getNumberOfSlots() |
int |
getPageSize() |
ResourceID |
getResourceID() |
Optional<Time> |
getSystemResourceMetricsProbingInterval() |
String[] |
getTmpDirPaths() |
public TaskManagerServicesConfiguration(Configuration configuration, ResourceID resourceID, InetAddress taskManagerAddress, boolean localCommunicationOnly, String[] tmpDirPaths, String[] localRecoveryStateRootDirectories, long freeHeapMemoryWithDefrag, long maxJvmHeapMemory, boolean localRecoveryEnabled, @Nullable QueryableStateConfiguration queryableStateConfig, int numberOfSlots, long configuredMemory, MemoryType memoryType, boolean preAllocateMemory, float memoryFraction, int pageSize, long timerServiceShutdownTimeout, RetryingRegistrationConfiguration retryingRegistrationConfiguration, Optional<Time> systemResourceMetricsProbingInterval)
public Configuration getConfiguration()
public ResourceID getResourceID()
public String[] getTmpDirPaths()
public int getNumberOfSlots()
public float getMemoryFraction()
public int getPageSize()
public Optional<Time> getSystemResourceMetricsProbingInterval()
public static TaskManagerServicesConfiguration fromConfiguration(Configuration configuration, ResourceID resourceID, InetAddress remoteAddress, long freeHeapMemoryWithDefrag, long maxJvmHeapMemory, boolean localCommunicationOnly)
configuration
- The configuration.resourceID
- resource ID of the task managerremoteAddress
- identifying the IP address under which the TaskManager will be accessiblefreeHeapMemoryWithDefrag
- an estimate of the size of the free heap memorymaxJvmHeapMemory
- the maximum JVM heap sizelocalCommunicationOnly
- True if only local communication is possible.
Use only in cases where only one task manager runs.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.