org.apache.flink.core.execution

Interface PipelineExecutorFactory

All Known Implementing Classes:

EmbeddedExecutorFactory, KubernetesSessionClusterExecutorFactory, LocalExecutorFactory, RemoteExecutorFactory, WebSubmissionExecutorFactory, YarnJobClusterExecutorFactory, YarnSessionClusterExecutorFactory

@Internal
public interface PipelineExecutorFactory

A factory for selecting and instantiating the adequate PipelineExecutor based on a provided Configuration.

Method Summary

Modifier and Type	Method and 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.

Method Detail

getName

String getName()

Returns the name of the executor that this factory creates.

isCompatibleWith

boolean isCompatibleWith(Configuration configuration)

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

getExecutor

PipelineExecutor getExecutor(Configuration configuration)

Instantiates an PipelineExecutor compatible with the provided configuration.

Returns:

the executor instance.