Package org.apache.flink.runtime.jobmaster

Interface SlotPoolServiceSchedulerFactory

All Known Implementing Classes:

DefaultSlotPoolServiceSchedulerFactory

public interface SlotPoolServiceSchedulerFactory

Factory for SlotPoolService and SchedulerNG.

Method Summary

Modifier and Type	Method	Description
SchedulerNG	createScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, org.apache.flink.configuration.Configuration configuration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, org.apache.flink.api.common.time.Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, org.apache.flink.api.common.time.Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor mainThreadExecutor, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<org.apache.flink.core.failure.FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)	Creates a SchedulerNG.
SlotPoolService	createSlotPoolService(org.apache.flink.api.common.JobID jid, DeclarativeSlotPoolFactory declarativeSlotPoolFactory)	Creates a SlotPoolService.
org.apache.flink.configuration.JobManagerOptions.SchedulerType	getSchedulerType()	Returns the scheduler type this factory is creating.

Method Detail

createSlotPoolService

SlotPoolService createSlotPoolService(org.apache.flink.api.common.JobID jid,
                                      DeclarativeSlotPoolFactory declarativeSlotPoolFactory)

Creates a SlotPoolService.

Parameters:

jid - jid is the JobID to pass to the service

declarativeSlotPoolFactory - the declarative slot pool factory

Returns:

created SlotPoolService

getSchedulerType

org.apache.flink.configuration.JobManagerOptions.SchedulerType getSchedulerType()

Returns the scheduler type this factory is creating.

Returns:

the scheduler type this factory is creating.

createScheduler

SchedulerNG createScheduler(org.slf4j.Logger log,
                            JobGraph jobGraph,
                            Executor ioExecutor,
                            org.apache.flink.configuration.Configuration configuration,
                            SlotPoolService slotPoolService,
                            ScheduledExecutorService futureExecutor,
                            ClassLoader userCodeLoader,
                            CheckpointRecoveryFactory checkpointRecoveryFactory,
                            org.apache.flink.api.common.time.Time rpcTimeout,
                            BlobWriter blobWriter,
                            JobManagerJobMetricGroup jobManagerJobMetricGroup,
                            org.apache.flink.api.common.time.Time slotRequestTimeout,
                            ShuffleMaster<?> shuffleMaster,
                            JobMasterPartitionTracker partitionTracker,
                            ExecutionDeploymentTracker executionDeploymentTracker,
                            long initializationTimestamp,
                            org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor mainThreadExecutor,
                            org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler,
                            JobStatusListener jobStatusListener,
                            Collection<org.apache.flink.core.failure.FailureEnricher> failureEnrichers,
                            BlocklistOperations blocklistOperations)
                     throws Exception

Creates a SchedulerNG.

Returns:

created SchedulerNG

Throws:

Exception - if the scheduler creation fails