Package | Description |
---|---|
org.apache.flink.client.deployment | |
org.apache.flink.client.deployment.executors | |
org.apache.flink.kubernetes | |
org.apache.flink.yarn |
Modifier and Type | Class and Description |
---|---|
class |
AbstractContainerizedClusterClientFactory<ClusterID>
An abstract
ClusterClientFactory containing some common implementations for different
containerized deployment clusters. |
class |
StandaloneClientFactory
A
ClusterClientFactory for a standalone cluster, i.e. |
Modifier and Type | Method and Description |
---|---|
<ClusterID> |
DefaultClusterClientServiceLoader.getClusterClientFactory(Configuration configuration) |
<ClusterID> |
ClusterClientServiceLoader.getClusterClientFactory(Configuration configuration)
Discovers the appropriate
ClusterClientFactory based on the provided configuration. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>
Deprecated.
|
class |
AbstractSessionClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>
An abstract
PipelineExecutor used to execute pipelines on an existing
(session) cluster. |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesClusterClientFactory
A
ClusterClientFactory for a Kubernetes cluster. |
Modifier and Type | Class and Description |
---|---|
class |
YarnClusterClientFactory
A
ClusterClientFactory for a YARN cluster. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.