public class TaskManagerConfiguration extends Object implements TaskManagerRuntimeInfo
TaskExecutor
.Constructor and Description |
---|
TaskManagerConfiguration(int numberSlots,
ResourceProfile defaultSlotResourceProfile,
ResourceProfile totalResourceProfile,
String[] tmpDirectories,
Time rpcTimeout,
Time slotTimeout,
java.time.Duration maxRegistrationDuration,
Configuration configuration,
boolean exitJvmOnOutOfMemory,
String taskManagerLogPath,
String taskManagerStdoutPath,
String taskManagerLogDir,
String taskManagerExternalAddress,
File tmpWorkingDirectory,
RetryingRegistrationConfiguration retryingRegistrationConfiguration) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getTaskManagerBindAddress
public TaskManagerConfiguration(int numberSlots, ResourceProfile defaultSlotResourceProfile, ResourceProfile totalResourceProfile, String[] tmpDirectories, Time rpcTimeout, Time slotTimeout, @Nullable java.time.Duration maxRegistrationDuration, Configuration configuration, boolean exitJvmOnOutOfMemory, @Nullable String taskManagerLogPath, @Nullable String taskManagerStdoutPath, @Nullable String taskManagerLogDir, String taskManagerExternalAddress, File tmpWorkingDirectory, RetryingRegistrationConfiguration retryingRegistrationConfiguration)
public int getNumberSlots()
public ResourceProfile getDefaultSlotResourceProfile()
public ResourceProfile getTotalResourceProfile()
public Time getRpcTimeout()
public Time getSlotTimeout()
@Nullable public java.time.Duration getMaxRegistrationDuration()
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 String getTaskManagerExternalAddress()
TaskManagerRuntimeInfo
getTaskManagerExternalAddress
in interface TaskManagerRuntimeInfo
public File getTmpWorkingDirectory()
TaskManagerRuntimeInfo
getTmpWorkingDirectory
in interface TaskManagerRuntimeInfo
public RetryingRegistrationConfiguration getRetryingRegistrationConfiguration()
public static TaskManagerConfiguration fromConfiguration(Configuration configuration, TaskExecutorResourceSpec taskExecutorResourceSpec, String externalAddress, File tmpWorkingDirectory)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.