@Internal public class EmbeddedExecutorFactory extends Object implements PipelineExecutorFactory
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns the name of the executor that this factory creates.
public EmbeddedExecutorFactory(Collection<JobID> submittedJobIds, DispatcherGateway dispatcherGateway, ScheduledExecutor retryExecutor)
submittedJobIds- a list that is going to be filled with 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 String getName()
public boolean isCompatibleWith(Configuration configuration)
trueif this factory is compatible with the options in the provided configuration,
public PipelineExecutor getExecutor(Configuration configuration)
PipelineExecutorcompatible with the provided configuration.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.