org.apache.flink.runtime.taskexecutor

Class TaskManagerServices

java.lang.Object

org.apache.flink.runtime.taskexecutor.TaskManagerServices

public class TaskManagerServices
extends Object

Container for TaskExecutor services such as the MemoryManager, IOManager, ShuffleEnvironment. All services are exclusive to a single TaskExecutor. Consequently, the respective TaskExecutor is responsible for closing them.

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOCAL_STATE_SUB_DIRECTORY_ROOT

Method Summary

Modifier and Type	Method and Description
static TaskManagerServices	fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration, PermanentBlobService permanentBlobService, MetricGroup taskManagerMetricGroup, ExecutorService ioExecutor, FatalErrorHandler fatalErrorHandler) Creates and returns the task manager services.
BroadcastVariableManager	getBroadcastVariableManager()
Executor	getIOExecutor()
IOManager	getIOManager()
JobLeaderService	getJobLeaderService()
JobTable	getJobTable()
KvStateService	getKvStateService()
LibraryCacheManager	getLibraryCacheManager()
ShuffleEnvironment<?,?>	getShuffleEnvironment()
TaskEventDispatcher	getTaskEventDispatcher()
TaskExecutorLocalStateStoresManager	getTaskManagerStateStore()
TaskSlotTable<Task>	getTaskSlotTable()
UnresolvedTaskManagerLocation	getUnresolvedTaskManagerLocation()
void	shutDown() Shuts the TaskExecutor services down.

Methods inherited from class java.lang.Object

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

Field Detail

LOCAL_STATE_SUB_DIRECTORY_ROOT

@VisibleForTesting
public static final String LOCAL_STATE_SUB_DIRECTORY_ROOT

See Also:

Constant Field Values

Method Detail

getIOManager

public IOManager getIOManager()

getShuffleEnvironment

public ShuffleEnvironment<?,?> getShuffleEnvironment()

getKvStateService

public KvStateService getKvStateService()

getUnresolvedTaskManagerLocation

public UnresolvedTaskManagerLocation getUnresolvedTaskManagerLocation()

getBroadcastVariableManager

public BroadcastVariableManager getBroadcastVariableManager()

getTaskSlotTable

public TaskSlotTable<Task> getTaskSlotTable()

getJobTable

public JobTable getJobTable()

getJobLeaderService

public JobLeaderService getJobLeaderService()

getTaskManagerStateStore

public TaskExecutorLocalStateStoresManager getTaskManagerStateStore()

getTaskEventDispatcher

public TaskEventDispatcher getTaskEventDispatcher()

getIOExecutor

public Executor getIOExecutor()

getLibraryCacheManager

public LibraryCacheManager getLibraryCacheManager()

shutDown

public void shutDown()
              throws FlinkException

Shuts the TaskExecutor services down.

Throws:

FlinkException

fromConfiguration

public static TaskManagerServices fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration,
                                                    PermanentBlobService permanentBlobService,
                                                    MetricGroup taskManagerMetricGroup,
                                                    ExecutorService ioExecutor,
                                                    FatalErrorHandler fatalErrorHandler)
                                             throws Exception

Creates and returns the task manager services.

Parameters:

taskManagerServicesConfiguration - task manager configuration

permanentBlobService - permanentBlobService used by the services

taskManagerMetricGroup - metric group of the task manager

ioExecutor - executor for async IO operations

fatalErrorHandler - to handle class loading OOMs

Returns:

task manager components

Throws:

Exception