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, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler, DelegationTokenReceiverRepository delegationTokenReceiverRepository)

Method Detail

createTaskExecutor

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

Throws:

Exception