org.apache.flink.core.execution

Interface PipelineExecutorServiceLoader

All Known Implementing Classes:

DefaultExecutorServiceLoader, EmbeddedExecutorServiceLoader, MiniClusterPipelineExecutorServiceLoader, WebSubmissionExecutorServiceLoader

@Internal
public interface PipelineExecutorServiceLoader

An interface to be implemented by the entity responsible for finding the correct PipelineExecutor to execute a given Pipeline.

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.

Method Detail

getExecutorFactory

PipelineExecutorFactory getExecutorFactory(Configuration configuration)
                                    throws Exception

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.

Returns:

a compatible PipelineExecutorFactory.

Throws:

Exception - if there is more than one compatible factories, or something went wrong when loading the registered factories.

getExecutorNames

Stream<String> getExecutorNames()

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