public class MiniClusterPipelineExecutorServiceLoader extends Object implements PipelineExecutorServiceLoader
PipelineExecutorServiceLoader
that is hardwired to return PipelineExecutors
that use a given MiniCluster
.Constructor and Description |
---|
MiniClusterPipelineExecutorServiceLoader(MiniCluster miniCluster) |
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.
|
static Configuration |
updateConfigurationForMiniCluster(Configuration config,
Collection<Path> jarFiles,
Collection<URL> classPaths)
Populates a
Configuration that is compatible with this MiniClusterPipelineExecutorServiceLoader . |
public static final String NAME
public MiniClusterPipelineExecutorServiceLoader(MiniCluster miniCluster)
public static Configuration updateConfigurationForMiniCluster(Configuration config, Collection<Path> jarFiles, Collection<URL> classPaths)
Configuration
that is compatible with this MiniClusterPipelineExecutorServiceLoader
.public PipelineExecutorFactory getExecutorFactory(Configuration configuration)
PipelineExecutorServiceLoader
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.getExecutorFactory
in interface PipelineExecutorServiceLoader
PipelineExecutorFactory
.public Stream<String> getExecutorNames()
PipelineExecutorServiceLoader
getExecutorNames
in interface PipelineExecutorServiceLoader
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.