org.apache.flink.runtime.taskexecutor

Class TaskManagerServicesConfiguration

java.lang.Object

org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration

public class TaskManagerServicesConfiguration
extends Object

Configuration for the task manager services such as the memory manager, the io manager and the metric registry.

Constructor Summary

Constructors

Constructor and Description

TaskManagerServicesConfiguration(Configuration configuration, ResourceID resourceID, InetAddress taskManagerAddress, boolean localCommunicationOnly, String[] tmpDirPaths, String[] localRecoveryStateRootDirectories, boolean localRecoveryEnabled, QueryableStateConfiguration queryableStateConfig, int numberOfSlots, int pageSize, TaskExecutorResourceSpec taskExecutorResourceSpec, long timerServiceShutdownTimeout, RetryingRegistrationConfiguration retryingRegistrationConfiguration, Optional<Time> systemResourceMetricsProbingInterval, int numIoThreads)

Method Summary

Modifier and Type	Method and Description
static TaskManagerServicesConfiguration	fromConfiguration(Configuration configuration, ResourceID resourceID, InetAddress remoteAddress, boolean localCommunicationOnly, TaskExecutorResourceSpec taskExecutorResourceSpec) Utility method to extract TaskManager config parameters from the configuration and to sanity check them.
Configuration	getConfiguration()
MemorySize	getManagedMemorySize()
MemorySize	getNetworkMemorySize()
int	getNumberOfSlots()
int	getNumIoThreads()
int	getPageSize()
ResourceID	getResourceID()
Optional<Time>	getSystemResourceMetricsProbingInterval()
TaskExecutorResourceSpec	getTaskExecutorResourceSpec()
String[]	getTmpDirPaths()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskManagerServicesConfiguration

public TaskManagerServicesConfiguration(Configuration configuration,
                                        ResourceID resourceID,
                                        InetAddress taskManagerAddress,
                                        boolean localCommunicationOnly,
                                        String[] tmpDirPaths,
                                        String[] localRecoveryStateRootDirectories,
                                        boolean localRecoveryEnabled,
                                        @Nullable
                                        QueryableStateConfiguration queryableStateConfig,
                                        int numberOfSlots,
                                        int pageSize,
                                        TaskExecutorResourceSpec taskExecutorResourceSpec,
                                        long timerServiceShutdownTimeout,
                                        RetryingRegistrationConfiguration retryingRegistrationConfiguration,
                                        Optional<Time> systemResourceMetricsProbingInterval,
                                        int numIoThreads)

Method Detail

getConfiguration

public Configuration getConfiguration()

getResourceID

public ResourceID getResourceID()

getTmpDirPaths

public String[] getTmpDirPaths()

getNumberOfSlots

public int getNumberOfSlots()

getPageSize

public int getPageSize()

getTaskExecutorResourceSpec

public TaskExecutorResourceSpec getTaskExecutorResourceSpec()

getNetworkMemorySize

public MemorySize getNetworkMemorySize()

getManagedMemorySize

public MemorySize getManagedMemorySize()

getSystemResourceMetricsProbingInterval

public Optional<Time> getSystemResourceMetricsProbingInterval()

getNumIoThreads

public int getNumIoThreads()

fromConfiguration

public static TaskManagerServicesConfiguration fromConfiguration(Configuration configuration,
                                                                 ResourceID resourceID,
                                                                 InetAddress remoteAddress,
                                                                 boolean localCommunicationOnly,
                                                                 TaskExecutorResourceSpec taskExecutorResourceSpec)

Utility method to extract TaskManager config parameters from the configuration and to sanity check them.

Parameters:

configuration - The configuration.

resourceID - resource ID of the task manager

remoteAddress - identifying the IP address under which the TaskManager will be accessible

localCommunicationOnly - True if only local communication is possible. Use only in cases where only one task manager runs.

Returns:

configuration of task manager services used to create them