Package org.apache.flink.core.execution
Interface PipelineExecutorFactory
-
@Internal public interface PipelineExecutorFactoryA factory for selecting and instantiating the adequatePipelineExecutorbased on a providedConfiguration.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PipelineExecutorgetExecutor(Configuration configuration)Instantiates anPipelineExecutorcompatible with the provided configuration.StringgetName()Returns the name of the executor that this factory creates.booleanisCompatibleWith(Configuration configuration)Returnstrueif this factory is compatible with the options in the provided configuration,falseotherwise.
-
-
-
Method Detail
-
getName
String getName()
Returns the name of the executor that this factory creates.
-
isCompatibleWith
boolean isCompatibleWith(Configuration configuration)
Returnstrueif this factory is compatible with the options in the provided configuration,falseotherwise.
-
getExecutor
PipelineExecutor getExecutor(Configuration configuration)
Instantiates anPipelineExecutorcompatible with the provided configuration.- Returns:
- the executor instance.
-
-