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