org.apache.flink.runtime.entrypoint.component

Class DefaultDispatcherResourceManagerComponentFactory

java.lang.Object

org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory

All Implemented Interfaces:

DispatcherResourceManagerComponentFactory

public class DefaultDispatcherResourceManagerComponentFactory
extends Object
implements DispatcherResourceManagerComponentFactory

Abstract class which implements the creation of the DispatcherResourceManagerComponent components.

Constructor Summary

Constructors

Constructor and Description
DefaultDispatcherResourceManagerComponentFactory(DispatcherRunnerFactory dispatcherRunnerFactory, ResourceManagerFactory<?> resourceManagerFactory, RestEndpointFactory<?> restEndpointFactory)

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)
static DefaultDispatcherResourceManagerComponentFactory	createJobComponentFactory(ResourceManagerFactory<?> resourceManagerFactory, JobGraphRetriever jobGraphRetriever)
static DefaultDispatcherResourceManagerComponentFactory	createSessionComponentFactory(ResourceManagerFactory<?> resourceManagerFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDispatcherResourceManagerComponentFactory

public DefaultDispatcherResourceManagerComponentFactory(@Nonnull
                                                        DispatcherRunnerFactory dispatcherRunnerFactory,
                                                        @Nonnull
                                                        ResourceManagerFactory<?> resourceManagerFactory,
                                                        @Nonnull
                                                        RestEndpointFactory<?> restEndpointFactory)

Method Detail

create

public 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

Specified by:

create in interface DispatcherResourceManagerComponentFactory

Throws:

Exception

createSessionComponentFactory

public static DefaultDispatcherResourceManagerComponentFactory createSessionComponentFactory(ResourceManagerFactory<?> resourceManagerFactory)

createJobComponentFactory

public static DefaultDispatcherResourceManagerComponentFactory createJobComponentFactory(ResourceManagerFactory<?> resourceManagerFactory,
                                                                                         JobGraphRetriever jobGraphRetriever)