Package | Description |
---|---|
org.apache.flink.client.deployment.executors | |
org.apache.flink.core.execution | |
org.apache.flink.kubernetes.executors | |
org.apache.flink.yarn.executors |
Modifier and Type | Class and Description |
---|---|
class |
LocalExecutorFactory
|
class |
RemoteExecutorFactory
|
Modifier and Type | Method and Description |
---|---|
PipelineExecutorFactory |
DefaultExecutorServiceLoader.getExecutorFactory(Configuration configuration) |
PipelineExecutorFactory |
PipelineExecutorServiceLoader.getExecutorFactory(Configuration configuration)
Loads the
PipelineExecutorFactory which is compatible with the provided configuration. |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesSessionClusterExecutorFactory
An
PipelineExecutorFactory for executing jobs on an existing (session) cluster. |
Modifier and Type | Class and Description |
---|---|
class |
YarnJobClusterExecutorFactory
An
PipelineExecutorFactory for executing jobs on dedicated (per-job) clusters. |
class |
YarnSessionClusterExecutorFactory
An
PipelineExecutorFactory for executing jobs on an existing (session) cluster. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.