Package org.apache.flink.client.deployment.application.executors

Class EmbeddedExecutorFactory

java.lang.Object

org.apache.flink.client.deployment.application.executors.EmbeddedExecutorFactory

All Implemented Interfaces:

PipelineExecutorFactory

@Internal
public class EmbeddedExecutorFactory
extends Object
implements PipelineExecutorFactory

An PipelineExecutorFactory for the EmbeddedExecutor.

Constructor Summary

Constructors

Constructor	Description
EmbeddedExecutorFactory(Collection<JobID> submittedJobIds, DispatcherGateway dispatcherGateway, ScheduledExecutor retryExecutor)	Creates an EmbeddedExecutorFactory.

Method Summary

Modifier and Type	Method	Description
PipelineExecutor	getExecutor(Configuration configuration)	Instantiates an PipelineExecutor compatible with the provided configuration.
String	getName()	Returns the name of the executor that this factory creates.
boolean	isCompatibleWith(Configuration configuration)	Returns true if this factory is compatible with the options in the provided configuration, false otherwise.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EmbeddedExecutorFactory

public EmbeddedExecutorFactory(Collection<JobID> submittedJobIds,
                               DispatcherGateway dispatcherGateway,
                               ScheduledExecutor retryExecutor)

Creates an EmbeddedExecutorFactory.

Parameters:

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.

Method Detail

getName

public String getName()

Description copied from interface: PipelineExecutorFactory

Returns the name of the executor that this factory creates.

Specified by:

getName in interface PipelineExecutorFactory

isCompatibleWith

public boolean isCompatibleWith(Configuration configuration)

Description copied from interface: PipelineExecutorFactory

Returns true if this factory is compatible with the options in the provided configuration, false otherwise.

Specified by:

isCompatibleWith in interface PipelineExecutorFactory

getExecutor

public PipelineExecutor getExecutor(Configuration configuration)

Description copied from interface: PipelineExecutorFactory

Instantiates an PipelineExecutor compatible with the provided configuration.

Specified by:

getExecutor in interface PipelineExecutorFactory

Returns:

the executor instance.