| Package | Description |
|---|---|
| org.apache.flink.runtime.client |
| Modifier and Type | Method and Description |
|---|---|
static SerializedJobExecutionResult |
JobClient.submitJobAndWait(akka.actor.ActorSystem actorSystem,
akka.actor.ActorRef jobManager,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates)
Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to
the JobManager.
|
static void |
JobClient.submitJobDetached(akka.actor.ActorRef jobManager,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout)
Submits a job in detached mode.
|
static void |
JobClient.uploadJarFiles(JobGraph jobGraph,
akka.actor.ActorRef jobManager,
scala.concurrent.duration.FiniteDuration timeout)
Uploads the specified jar files of the [[JobGraph]] jobGraph to the BlobServer of the
JobManager.
|
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.