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.minicluster | |
org.apache.flink.runtime.webmonitor.handlers | |
org.apache.flink.streaming.api.graph |
Modifier and Type | Method and Description |
---|---|
JobGraph |
Client.getJobGraph(PackagedProgram prog,
FlinkPlan optPlan) |
JobGraph |
Client.getJobGraph(PackagedProgram prog,
FlinkPlan optPlan,
String savepointPath) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
Client.runBlocking(JobGraph jobGraph,
ClassLoader classLoader) |
JobSubmissionResult |
Client.runDetached(JobGraph jobGraph,
ClassLoader classLoader) |
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.
|
static void |
JobClient.uploadJarFiles(JobGraph jobGraph,
ActorGateway jobManagerGateway,
scala.concurrent.duration.FiniteDuration timeout)
Uploads the specified jar files of the [[JobGraph]] jobGraph to the BlobServer of the
JobManager.
|
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 |
---|---|
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 . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.