Package org.apache.flink.yarn.executors
Class YarnJobClusterExecutorFactory
- java.lang.Object
-
- org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory
-
- All Implemented Interfaces:
PipelineExecutorFactory
@Internal @Deprecated public class YarnJobClusterExecutorFactory extends Object implements PipelineExecutorFactory
Deprecated.AnPipelineExecutorFactory
for executing jobs on dedicated (per-job) clusters.
-
-
Constructor Summary
Constructors Constructor Description YarnJobClusterExecutorFactory()
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description PipelineExecutor
getExecutor(Configuration configuration)
Deprecated.Instantiates anPipelineExecutor
compatible with the provided configuration.String
getName()
Deprecated.Returns the name of the executor that this factory creates.boolean
isCompatibleWith(Configuration configuration)
Deprecated.Returnstrue
if this factory is compatible with the options in the provided configuration,false
otherwise.
-
-
-
Method Detail
-
getName
public String getName()
Deprecated.Description copied from interface:PipelineExecutorFactory
Returns the name of the executor that this factory creates.- Specified by:
getName
in interfacePipelineExecutorFactory
-
isCompatibleWith
public boolean isCompatibleWith(@Nonnull Configuration configuration)
Deprecated.Description copied from interface:PipelineExecutorFactory
Returnstrue
if this factory is compatible with the options in the provided configuration,false
otherwise.- Specified by:
isCompatibleWith
in interfacePipelineExecutorFactory
-
getExecutor
public PipelineExecutor getExecutor(@Nonnull Configuration configuration)
Deprecated.Description copied from interface:PipelineExecutorFactory
Instantiates anPipelineExecutor
compatible with the provided configuration.- Specified by:
getExecutor
in interfacePipelineExecutorFactory
- Returns:
- the executor instance.
-
-