Package 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 correctPipelineExecutor
to execute a givenPipeline
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PipelineExecutorFactory
getExecutorFactory(Configuration configuration)
Loads thePipelineExecutorFactory
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 thePipelineExecutorFactory
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.
-
-