org.apache.flink.client.deployment.application.executors

Class EmbeddedExecutorServiceLoader

java.lang.Object

org.apache.flink.client.deployment.application.executors.EmbeddedExecutorServiceLoader

All Implemented Interfaces:

PipelineExecutorServiceLoader

@Internal
public class EmbeddedExecutorServiceLoader
extends Object
implements PipelineExecutorServiceLoader

A PipelineExecutorServiceLoader that always returns an EmbeddedExecutorFactory. This is useful when running the user's main on the cluster.

Constructor Summary

Constructors

Constructor and Description
EmbeddedExecutorServiceLoader(Collection<JobID> submittedJobIds, DispatcherGateway dispatcherGateway, ScheduledExecutor retryExecutor) Creates an EmbeddedExecutorServiceLoader.

Method Summary

Modifier and Type	Method and Description
PipelineExecutorFactory	getExecutorFactory(Configuration configuration) Loads the PipelineExecutorFactory which is compatible with the provided configuration.
Stream<String>	getExecutorNames() Loads and returns a stream of the names of all available executors.

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedExecutorServiceLoader

public EmbeddedExecutorServiceLoader(Collection<JobID> submittedJobIds,
                                     DispatcherGateway dispatcherGateway,
                                     ScheduledExecutor retryExecutor)

Creates an EmbeddedExecutorServiceLoader.

Parameters:

submittedJobIds - a list that is going to be filled by the EmbeddedExecutor with the job ids of the new jobs that will be submitted. This is essentially used to return the submitted job ids to the caller.

dispatcherGateway - the dispatcher of the cluster which is going to be used to submit jobs.

Method Detail

getExecutorFactory

public PipelineExecutorFactory getExecutorFactory(Configuration configuration)

Description copied from interface: PipelineExecutorServiceLoader

Loads the PipelineExecutorFactory which is compatible with the provided configuration. There can be at most one compatible factory among the available ones, otherwise an exception will be thrown.

Specified by:

getExecutorFactory in interface PipelineExecutorServiceLoader

Returns:

a compatible PipelineExecutorFactory.

getExecutorNames

public Stream<String> getExecutorNames()

Description copied from interface: PipelineExecutorServiceLoader

Loads and returns a stream of the names of all available executors.

Specified by:

getExecutorNames in interface PipelineExecutorServiceLoader