KubernetesSessionClusterExecutor (Flink : Kubernetes 2.1.1-cp2 API)

java.lang.Object
- org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor<String,KubernetesClusterClientFactory>
- - org.apache.flink.kubernetes.executors.KubernetesSessionClusterExecutor

All Implemented Interfaces:

org.apache.flink.core.execution.CacheSupportedPipelineExecutor, org.apache.flink.core.execution.PipelineExecutor
```
@Internal
public class KubernetesSessionClusterExecutor
extends org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor<String,KubernetesClusterClientFactory>
```
The PipelineExecutor to be used when executing a job on an already running cluster.

- Field Summary
  
  Fields
  Modifier and Type Field Description
  
  static String NAME
- Constructor Summary
  
  Constructors
  Constructor Description
  
  KubernetesSessionClusterExecutor(org.apache.flink.configuration.Configuration configuration)
- Method Summary
  - Methods inherited from class org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor
    execute, invalidateClusterDataset, listCompletedClusterDatasetIds
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail
- NAME
```
public static final String NAME
```

Constructor Detail

KubernetesSessionClusterExecutor

public KubernetesSessionClusterExecutor(org.apache.flink.configuration.Configuration configuration)