YarnSessionClusterExecutorFactory (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.yarn.executors.YarnSessionClusterExecutorFactory

All Implemented Interfaces:

PipelineExecutorFactory
```
@Internal
public class YarnSessionClusterExecutorFactory
extends Object
implements PipelineExecutorFactory
```
An PipelineExecutorFactory for executing jobs on an existing (session) cluster.

Constructor Summary

Constructors
Constructor Description

YarnSessionClusterExecutorFactory()

Method Summary

All Methods Instance Methods Concrete Methods
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
  - YarnSessionClusterExecutorFactory
```
public YarnSessionClusterExecutorFactory()
```
- 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(@Nonnull
                                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(@Nonnull
                                    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.