Package 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	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, Collection<FailureEnricher> failureEnrichers, 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,
                                          Collection<FailureEnricher> failureEnrichers,
                                          FatalErrorHandler fatalErrorHandler)
                                   throws Exception

Throws:

Exception