YarnSessionClusterEntrypoint (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.entrypoint.ClusterEntrypoint
- - org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint
  - - org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

All Implemented Interfaces:

AutoCloseable, FatalErrorHandler, AutoCloseableAsync
```
public class YarnSessionClusterEntrypoint
extends SessionClusterEntrypoint
```
Entry point for Yarn session clusters.

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint
  ClusterEntrypoint.ExecutionMode, ClusterEntrypoint.ShutdownBehaviour

Field Summary
- Fields inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint
  INTERNAL_CLUSTER_EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE

Constructor Summary

Constructors
Constructor Description

YarnSessionClusterEntrypoint(Configuration configuration)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected DispatcherResourceManagerComponentFactory`	`createDispatcherResourceManagerComponentFactory(Configuration configuration)`
`protected String`	`getRPCPortRange(Configuration configuration)`	Returns the port range for the common `RpcService`.
`static void`	`main(String[] args)`

Methods inherited from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint
createSerializableExecutionGraphStore

Methods inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint
cleanupDirectories, closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRestPort, getRpcPort, getTerminationFuture, initializeServices, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster, stopClusterServices, supportsReactiveMode

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync
close

- Constructor Detail
  - YarnSessionClusterEntrypoint
```
public YarnSessionClusterEntrypoint(Configuration configuration)
```
- Method Detail
  - getRPCPortRange
```
protected String getRPCPortRange(Configuration configuration)
```
    Description copied from class: ClusterEntrypoint
    
    Returns the port range for the common RpcService.
    
    Overrides:
    
    getRPCPortRange in class ClusterEntrypoint
    
    Parameters:
    
    configuration - to extract the port range from
    
    Returns:
    
    Port range for the common RpcService
  - createDispatcherResourceManagerComponentFactory
```
protected DispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory(Configuration configuration)
```
    Specified by:
    
    createDispatcherResourceManagerComponentFactory in class ClusterEntrypoint
  - main
```
public static void main(String[] args)
```