org.apache.flink.runtime.scheduler

Class DefaultSchedulerFactory

java.lang.Object

org.apache.flink.runtime.scheduler.DefaultSchedulerFactory

All Implemented Interfaces:

SchedulerNGFactory

public class DefaultSchedulerFactory
extends Object
implements SchedulerNGFactory

Factory for DefaultScheduler.

Constructor Summary

Constructors

Constructor and Description
DefaultSchedulerFactory()

Method Summary

Modifier and Type

Method and Description

SchedulerNG

createInstance(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSchedulerFactory

public DefaultSchedulerFactory()

Method Detail

createInstance

public SchedulerNG createInstance(org.slf4j.Logger log,
                                  JobGraph jobGraph,
                                  BackPressureStatsTracker backPressureStatsTracker,
                                  Executor ioExecutor,
                                  Configuration jobMasterConfiguration,
                                  SlotProvider slotProvider,
                                  ScheduledExecutorService futureExecutor,
                                  ClassLoader userCodeLoader,
                                  CheckpointRecoveryFactory checkpointRecoveryFactory,
                                  Time rpcTimeout,
                                  BlobWriter blobWriter,
                                  JobManagerJobMetricGroup jobManagerJobMetricGroup,
                                  Time slotRequestTimeout,
                                  ShuffleMaster<?> shuffleMaster,
                                  JobMasterPartitionTracker partitionTracker)
                           throws Exception

Specified by:

createInstance in interface SchedulerNGFactory

Throws:

Exception