Package org.apache.flink.core.execution
Interface PipelineExecutorServiceLoader
-
- All Known Implementing Classes:
DefaultExecutorServiceLoader
@Internal public interface PipelineExecutorServiceLoaderAn interface to be implemented by the entity responsible for finding the correctPipelineExecutorto execute a givenPipeline.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PipelineExecutorFactorygetExecutorFactory(Configuration configuration)Loads thePipelineExecutorFactorywhich is compatible with the provided configuration.java.util.stream.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 thePipelineExecutorFactorywhich 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
java.util.stream.Stream<String> getExecutorNames()
Loads and returns a stream of the names of all available executors.
-
-