|Constructor and Description|
|Modifier and Type||Method and Description|
Loads and returns a stream of the names of all available executors.
public EmbeddedExecutorServiceLoader(Collection<JobID> submittedJobIds, DispatcherGateway dispatcherGateway, ScheduledExecutor retryExecutor)
submittedJobIds- a list that is going to be filled by the
EmbeddedExecutorwith the job ids of the new jobs that will be submitted. This is essentially used to return the submitted job ids to the caller.
dispatcherGateway- the dispatcher of the cluster which is going to be used to submit jobs.
public PipelineExecutorFactory getExecutorFactory(Configuration configuration)
PipelineExecutorFactorywhich is compatible with the provided configuration. There can be at most one compatible factory among the available ones, otherwise an exception will be thrown.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.