Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.optimizer.plan | |
org.apache.flink.optimizer.plantranslate | |
org.apache.flink.runtime.client | |
org.apache.flink.runtime.jobgraph.jsonplan | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.runtime.minicluster | |
org.apache.flink.runtime.webmonitor.handlers | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
JobGraph |
ClusterClient.getJobGraph(PackagedProgram prog,
FlinkPlan optPlan) |
JobGraph |
ClusterClient.getJobGraph(PackagedProgram prog,
FlinkPlan optPlan,
SavepointRestoreSettings savepointSettings) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ClusterClient.run(JobGraph jobGraph,
ClassLoader classLoader)
Submits a JobGraph blocking.
|
JobSubmissionResult |
ClusterClient.runDetached(JobGraph jobGraph,
ClassLoader classLoader)
Submits a JobGraph detached.
|
protected JobSubmissionResult |
StandaloneClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
protected abstract JobSubmissionResult |
ClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader)
Calls the subclasses' submitJob method.
|
Modifier and Type | Method and Description |
---|---|
abstract JobGraph |
StreamingPlan.getJobGraph() |
Modifier and Type | Method and Description |
---|---|
JobGraph |
JobGraphGenerator.compileJobGraph(OptimizedPlan program)
Translates a
OptimizedPlan into a
JobGraph . |
JobGraph |
JobGraphGenerator.compileJobGraph(OptimizedPlan program,
JobID jobId) |
Modifier and Type | Method and Description |
---|---|
static JobExecutionResult |
JobClient.submitJobAndWait(akka.actor.ActorSystem actorSystem,
LeaderRetrievalService leaderRetrievalService,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates,
ClassLoader classLoader)
Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to
the JobManager.
|
static void |
JobClient.submitJobDetached(ActorGateway jobManagerGateway,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
ClassLoader classLoader)
Submits a job in detached mode.
|
Modifier and Type | Method and Description |
---|---|
static String |
JsonPlanGenerator.generatePlan(JobGraph jg) |
Modifier and Type | Method and Description |
---|---|
JobGraph |
SubmittedJobGraph.getJobGraph()
Returns the submitted
JobGraph . |
Constructor and Description |
---|
SubmittedJobGraph(JobGraph jobGraph,
JobInfo jobInfo)
Creates a
SubmittedJobGraph . |
Modifier and Type | Method and Description |
---|---|
JobGraph |
JobClientMessages.SubmitJobAndWait.jobGraph() |
JobGraph |
JobClientMessages.SubmitJobDetached.jobGraph() |
JobGraph |
JobManagerMessages.SubmitJob.jobGraph() |
Constructor and Description |
---|
SubmitJob(JobGraph jobGraph,
ListeningBehaviour listeningBehaviour) |
SubmitJobAndWait(JobGraph jobGraph) |
SubmitJobDetached(JobGraph jobGraph) |
Modifier and Type | Method and Description |
---|---|
JobManagerJobMetricGroup |
JobManagerMetricGroup.addJob(JobGraph job) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
FlinkMiniCluster.submitJobAndWait(JobGraph jobGraph,
boolean printUpdates) |
JobExecutionResult |
FlinkMiniCluster.submitJobAndWait(JobGraph jobGraph,
boolean printUpdates,
scala.concurrent.duration.FiniteDuration timeout) |
JobExecutionResult |
FlinkMiniCluster.submitJobAndWait(JobGraph jobGraph,
boolean printUpdates,
scala.concurrent.duration.FiniteDuration timeout,
LeaderRetrievalService leaderRetrievalService) |
JobSubmissionResult |
FlinkMiniCluster.submitJobDetached(JobGraph jobGraph) |
Modifier and Type | Method and Description |
---|---|
protected Tuple2<JobGraph,ClassLoader> |
JarActionHandler.getJobGraphAndClassLoader(Map<String,String> pathParams,
Map<String,String> queryParams) |
Modifier and Type | Method and Description |
---|---|
JobGraph |
StreamingJobGraphGenerator.createJobGraph() |
JobGraph |
StreamGraph.getJobGraph()
Gets the assembled
JobGraph . |
Modifier and Type | Method and Description |
---|---|
protected JobSubmissionResult |
YarnClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.