org.apache.flink.runtime.taskexecutor

Interface TaskManagerRunner.TaskExecutorServiceFactory

Enclosing class:

TaskManagerRunner

public static interface TaskManagerRunner.TaskExecutorServiceFactory

Factory for TaskExecutor.

Method Summary

Modifier and Type	Method and Description
TaskManagerRunner.TaskExecutorService	createTaskExecutor(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, FatalErrorHandler fatalErrorHandler)

Method Detail

createTaskExecutor

TaskManagerRunner.TaskExecutorService createTaskExecutor(Configuration configuration,
                                                         ResourceID resourceID,
                                                         RpcService rpcService,
                                                         HighAvailabilityServices highAvailabilityServices,
                                                         HeartbeatServices heartbeatServices,
                                                         MetricRegistry metricRegistry,
                                                         BlobCacheService blobCacheService,
                                                         boolean localCommunicationOnly,
                                                         ExternalResourceInfoProvider externalResourceInfoProvider,
                                                         FatalErrorHandler fatalErrorHandler)
                                                  throws Exception

Throws:

Exception