public class Flip6StandaloneClusterDescriptor extends Object implements ClusterDescriptor<RestClusterClient>
Constructor and Description |
---|
Flip6StandaloneClusterDescriptor(Configuration config) |
Modifier and Type | Method and Description |
---|---|
RestClusterClient |
deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph)
Deploys a per-job cluster with the given job on the cluster.
|
RestClusterClient |
deploySessionCluster(ClusterSpecification clusterSpecification)
Triggers deployment of a cluster.
|
String |
getClusterDescription()
Returns a String containing details about the cluster (NodeManagers, available memory, ...).
|
RestClusterClient |
retrieve(String applicationID)
Retrieves an existing Flink Cluster.
|
public Flip6StandaloneClusterDescriptor(Configuration config)
public String getClusterDescription()
ClusterDescriptor
getClusterDescription
in interface ClusterDescriptor<RestClusterClient>
public RestClusterClient retrieve(String applicationID)
ClusterDescriptor
retrieve
in interface ClusterDescriptor<RestClusterClient>
applicationID
- The unique application identifier of the running clusterpublic RestClusterClient deploySessionCluster(ClusterSpecification clusterSpecification) throws UnsupportedOperationException
ClusterDescriptor
deploySessionCluster
in interface ClusterDescriptor<RestClusterClient>
clusterSpecification
- Cluster specification defining the cluster to deployUnsupportedOperationException
- if this cluster descriptor doesn't support the operationpublic RestClusterClient deployJobCluster(ClusterSpecification clusterSpecification, JobGraph jobGraph)
ClusterDescriptor
deployJobCluster
in interface ClusterDescriptor<RestClusterClient>
clusterSpecification
- Initial cluster specification with which the Flink cluster is launchedjobGraph
- JobGraph with which the job cluster is startedCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.