public class StandaloneClusterClient extends ClusterClient
ClusterClient.LazyActorSystemLoader
actorSystemLoader, flinkConfig, timeout
Constructor and Description |
---|
StandaloneClusterClient(Configuration config) |
Modifier and Type | Method and Description |
---|---|
protected void |
finalizeCluster()
Request the cluster to shut down or disconnect.
|
String |
getClusterIdentifier()
Returns a string representation of the cluster.
|
GetClusterStatusResponse |
getClusterStatus()
Returns the latest cluster status, with number of Taskmanagers and slots
|
int |
getMaxSlots()
The client may define an upper limit on the number of slots to use
|
List<String> |
getNewMessages()
May return new messages from the cluster.
|
String |
getWebInterfaceURL()
Returns an URL (as a string) to the JobManager web interface
|
protected JobSubmissionResult |
submitJob(JobGraph jobGraph,
ClassLoader classLoader)
Calls the subclasses' submitJob method.
|
void |
waitForClusterToBeReady()
Blocks until the client has determined that the cluster is ready for Job submission.
|
cancel, endSession, endSessions, getAccumulators, getAccumulators, getFlinkConfiguration, getJobGraph, getJobGraph, getJobManagerAddress, getJobManagerGateway, getOptimizedPlan, getOptimizedPlan, getOptimizedPlanAsJson, getPrintStatusDuringExecution, isDetached, logAndSysout, run, run, run, run, run, run, runDetached, setDetached, setPrintStatusDuringExecution, shutdown, stop
public StandaloneClusterClient(Configuration config) throws IOException
IOException
public void waitForClusterToBeReady()
ClusterClient
waitForClusterToBeReady
in class ClusterClient
public String getWebInterfaceURL()
ClusterClient
getWebInterfaceURL
in class ClusterClient
public GetClusterStatusResponse getClusterStatus()
ClusterClient
getClusterStatus
in class ClusterClient
public List<String> getNewMessages()
ClusterClient
getNewMessages
in class ClusterClient
public String getClusterIdentifier()
ClusterClient
getClusterIdentifier
in class ClusterClient
public int getMaxSlots()
ClusterClient
getMaxSlots
in class ClusterClient
protected JobSubmissionResult submitJob(JobGraph jobGraph, ClassLoader classLoader) throws ProgramInvocationException
ClusterClient
submitJob
in class ClusterClient
jobGraph
- The JobGraph to be submittedProgramInvocationException
protected void finalizeCluster()
ClusterClient
finalizeCluster
in class ClusterClient
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.