org.apache.flink.runtime.entrypoint.component

Interface DispatcherResourceManagerComponentFactory

All Known Implementing Classes:

DefaultDispatcherResourceManagerComponentFactory

public interface DispatcherResourceManagerComponentFactory

Factory for the DispatcherResourceManagerComponent.

Method Summary

Modifier and Type

Method and Description

DispatcherResourceManagerComponent

create(Configuration configuration, ResourceID resourceId, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)

Method Detail

create

DispatcherResourceManagerComponent create(Configuration configuration,
                                          ResourceID resourceId,
                                          Executor ioExecutor,
                                          RpcService rpcService,
                                          HighAvailabilityServices highAvailabilityServices,
                                          BlobServer blobServer,
                                          HeartbeatServices heartbeatServices,
                                          DelegationTokenManager delegationTokenManager,
                                          MetricRegistry metricRegistry,
                                          ExecutionGraphInfoStore executionGraphInfoStore,
                                          MetricQueryServiceRetriever metricQueryServiceRetriever,
                                          FatalErrorHandler fatalErrorHandler)
                                   throws Exception

Throws:

Exception