T
- Type of the cluster idpublic interface ClusterDescriptor<T> extends AutoCloseable
Modifier and Type | Method and Description |
---|---|
ClusterClient<T> |
deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph,
boolean detached)
Deploys a per-job cluster with the given job on the cluster.
|
ClusterClient<T> |
deploySessionCluster(ClusterSpecification clusterSpecification)
Triggers deployment of a cluster.
|
String |
getClusterDescription()
Returns a String containing details about the cluster (NodeManagers, available memory, ...).
|
void |
killCluster(T clusterId)
Terminates the cluster with the given cluster id.
|
ClusterClient<T> |
retrieve(T clusterId)
Retrieves an existing Flink Cluster.
|
close
String getClusterDescription()
ClusterClient<T> retrieve(T clusterId) throws ClusterRetrieveException
clusterId
- The unique identifier of the running clusterClusterRetrieveException
- if the cluster client could not be retrievedClusterClient<T> deploySessionCluster(ClusterSpecification clusterSpecification) throws ClusterDeploymentException
clusterSpecification
- Cluster specification defining the cluster to deployClusterDeploymentException
- if the cluster could not be deployedClusterClient<T> deployJobCluster(ClusterSpecification clusterSpecification, JobGraph jobGraph, boolean detached) throws ClusterDeploymentException
clusterSpecification
- Initial cluster specification with which the Flink cluster is launchedjobGraph
- JobGraph with which the job cluster is starteddetached
- true if the cluster should be stopped after the job completion without serving the result,
otherwise falseClusterDeploymentException
- if the cluster could not be deployedvoid killCluster(T clusterId) throws FlinkException
clusterId
- identifying the cluster to shut downFlinkException
- if the cluster could not be terminatedCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.