@Internal public interface PipelineExecutorServiceLoader
PipelineExecutor
to
execute a given Pipeline
.Modifier and Type | Method and Description |
---|---|
PipelineExecutorFactory |
getExecutorFactory(Configuration configuration)
Loads the
PipelineExecutorFactory which is compatible with the provided configuration. |
java.util.stream.Stream<String> |
getExecutorNames()
Loads and returns a stream of the names of all available executors.
|
PipelineExecutorFactory getExecutorFactory(Configuration configuration) throws Exception
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.PipelineExecutorFactory
.Exception
- if there is more than one compatible factories, or something went wrong when
loading the registered factories.java.util.stream.Stream<String> getExecutorNames()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.