org.apache.flink.runtime.entrypoint.component

Class AbstractDispatcherResourceManagerComponentFactory<T extends Dispatcher,U extends RestfulGateway>

java.lang.Object

org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory<T,U>

Type Parameters:

T - type of the Dispatcher

U - type of the RestfulGateway given to the WebMonitorEndpoint

All Implemented Interfaces:

DispatcherResourceManagerComponentFactory<T>

Direct Known Subclasses:

JobDispatcherResourceManagerComponentFactory, SessionDispatcherResourceManagerComponentFactory

public abstract class AbstractDispatcherResourceManagerComponentFactory<T extends Dispatcher,U extends RestfulGateway>
extends Object
implements DispatcherResourceManagerComponentFactory<T>

Abstract class which implements the creation of the DispatcherResourceManagerComponent components.

Constructor Summary

Constructors

Constructor and Description
AbstractDispatcherResourceManagerComponentFactory(DispatcherFactory<T> dispatcherFactory, ResourceManagerFactory<?> resourceManagerFactory, RestEndpointFactory<U> restEndpointFactory)

Method Summary

Modifier and Type	Method and Description
DispatcherResourceManagerComponent<T>	create(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ArchivedExecutionGraphStore archivedExecutionGraphStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
protected abstract DispatcherResourceManagerComponent<T>	createDispatcherResourceManagerComponent(T dispatcher, ResourceManager<?> resourceManager, LeaderRetrievalService dispatcherLeaderRetrievalService, LeaderRetrievalService resourceManagerRetrievalService, WebMonitorEndpoint<?> webMonitorEndpoint, JobManagerMetricGroup jobManagerMetricGroup)
protected String	getHostname(RpcService rpcService)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractDispatcherResourceManagerComponentFactory

public AbstractDispatcherResourceManagerComponentFactory(@Nonnull
                                                         DispatcherFactory<T> dispatcherFactory,
                                                         @Nonnull
                                                         ResourceManagerFactory<?> resourceManagerFactory,
                                                         @Nonnull
                                                         RestEndpointFactory<U> restEndpointFactory)

Method Detail

create

public DispatcherResourceManagerComponent<T> create(Configuration configuration,
                                                    RpcService rpcService,
                                                    HighAvailabilityServices highAvailabilityServices,
                                                    BlobServer blobServer,
                                                    HeartbeatServices heartbeatServices,
                                                    MetricRegistry metricRegistry,
                                                    ArchivedExecutionGraphStore archivedExecutionGraphStore,
                                                    MetricQueryServiceRetriever metricQueryServiceRetriever,
                                                    FatalErrorHandler fatalErrorHandler)
                                             throws Exception

Specified by:

create in interface DispatcherResourceManagerComponentFactory<T extends Dispatcher>

Throws:

Exception

getHostname

protected String getHostname(RpcService rpcService)

createDispatcherResourceManagerComponent

protected abstract DispatcherResourceManagerComponent<T> createDispatcherResourceManagerComponent(T dispatcher,
                                                                                                  ResourceManager<?> resourceManager,
                                                                                                  LeaderRetrievalService dispatcherLeaderRetrievalService,
                                                                                                  LeaderRetrievalService resourceManagerRetrievalService,
                                                                                                  WebMonitorEndpoint<?> webMonitorEndpoint,
                                                                                                  JobManagerMetricGroup jobManagerMetricGroup)