Package org.apache.flink.yarn.executors

Class YarnJobClusterExecutorFactory

java.lang.Object

org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory

All Implemented Interfaces:

org.apache.flink.core.execution.PipelineExecutorFactory

@Internal
@Deprecated
public class YarnJobClusterExecutorFactory
extends Object
implements org.apache.flink.core.execution.PipelineExecutorFactory

Deprecated.

An PipelineExecutorFactory for executing jobs on dedicated (per-job) clusters.

Constructor Summary

Constructors

Constructor	Description
YarnJobClusterExecutorFactory()	Deprecated.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.core.execution.PipelineExecutor	getExecutor(org.apache.flink.configuration.Configuration configuration)	Deprecated.
String	getName()	Deprecated.
boolean	isCompatibleWith(org.apache.flink.configuration.Configuration configuration)	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnJobClusterExecutorFactory

public YarnJobClusterExecutorFactory()

Deprecated.

Method Detail

getName

public String getName()

Deprecated.

Specified by:

getName in interface org.apache.flink.core.execution.PipelineExecutorFactory

isCompatibleWith

public boolean isCompatibleWith(@Nonnull
                                org.apache.flink.configuration.Configuration configuration)

Deprecated.

Specified by:

isCompatibleWith in interface org.apache.flink.core.execution.PipelineExecutorFactory

getExecutor

public org.apache.flink.core.execution.PipelineExecutor getExecutor(@Nonnull
                                                                    org.apache.flink.configuration.Configuration configuration)

Deprecated.

Specified by:

getExecutor in interface org.apache.flink.core.execution.PipelineExecutorFactory