org.apache.flink.runtime.jobmaster.factories

Class DefaultJobMasterServiceFactory

java.lang.Object

org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory

All Implemented Interfaces:

JobMasterServiceFactory

public class DefaultJobMasterServiceFactory
extends Object
implements JobMasterServiceFactory

Default implementation of the JobMasterServiceFactory.

Constructor Summary

Constructors

Constructor and Description
DefaultJobMasterServiceFactory(JobMasterConfiguration jobMasterConfiguration, SlotPoolFactory slotPoolFactory, SchedulerFactory schedulerFactory, RpcService rpcService, HighAvailabilityServices haServices, JobManagerSharedServices jobManagerSharedServices, HeartbeatServices heartbeatServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler)

Method Summary

Modifier and Type	Method and Description
JobMaster	createJobMasterService(JobGraph jobGraph, OnCompletionActions jobCompletionActions, ClassLoader userCodeClassloader)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultJobMasterServiceFactory

public DefaultJobMasterServiceFactory(JobMasterConfiguration jobMasterConfiguration,
                                      SlotPoolFactory slotPoolFactory,
                                      SchedulerFactory schedulerFactory,
                                      RpcService rpcService,
                                      HighAvailabilityServices haServices,
                                      JobManagerSharedServices jobManagerSharedServices,
                                      HeartbeatServices heartbeatServices,
                                      JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory,
                                      FatalErrorHandler fatalErrorHandler)

Method Detail

createJobMasterService

public JobMaster createJobMasterService(JobGraph jobGraph,
                                        OnCompletionActions jobCompletionActions,
                                        ClassLoader userCodeClassloader)
                                 throws Exception

Specified by:

createJobMasterService in interface JobMasterServiceFactory

Throws:

Exception