public class StandaloneClusterDescriptor extends Object implements ClusterDescriptor<StandaloneClusterClient>
Constructor and Description |
---|
StandaloneClusterDescriptor(Configuration config) |
Modifier and Type | Method and Description |
---|---|
StandaloneClusterClient |
deploy()
Triggers deployment of a cluster
|
String |
getClusterDescription()
Returns a String containing details about the cluster (NodeManagers, available memory, ...)
|
StandaloneClusterClient |
retrieve(String applicationID)
Retrieves an existing Flink Cluster.
|
public StandaloneClusterDescriptor(Configuration config)
public String getClusterDescription()
ClusterDescriptor
getClusterDescription
in interface ClusterDescriptor<StandaloneClusterClient>
public StandaloneClusterClient retrieve(String applicationID)
ClusterDescriptor
retrieve
in interface ClusterDescriptor<StandaloneClusterClient>
applicationID
- The unique application identifier of the running clusterpublic StandaloneClusterClient deploy() throws UnsupportedOperationException
ClusterDescriptor
deploy
in interface ClusterDescriptor<StandaloneClusterClient>
UnsupportedOperationException
- if this cluster descriptor doesn't support the operationCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.