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, RpcService rpcService, HighAvailabilityServices haServices, JobManagerSharedServices jobManagerSharedServices, HeartbeatServices heartbeatServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, SchedulerNGFactory schedulerNGFactory, ShuffleMaster<?> shuffleMaster)

Method Summary

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

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,
                                      RpcService rpcService,
                                      HighAvailabilityServices haServices,
                                      JobManagerSharedServices jobManagerSharedServices,
                                      HeartbeatServices heartbeatServices,
                                      JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory,
                                      FatalErrorHandler fatalErrorHandler,
                                      SchedulerNGFactory schedulerNGFactory,
                                      ShuffleMaster<?> shuffleMaster)

Method Detail

createJobMasterService

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

Specified by:

createJobMasterService in interface JobMasterServiceFactory

Throws:

Exception