Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.runtime.client |
Modifier and Type | Method and Description |
---|---|
JobListeningContext |
ClusterClient.connectToJob(JobID jobID)
Reattaches to a running job with the given job id.
|
Modifier and Type | Method and Description |
---|---|
static JobListeningContext |
JobClient.attachToRunningJob(JobID jobID,
Configuration configuration,
akka.actor.ActorSystem actorSystem,
HighAvailabilityServices highAvailabilityServices,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates)
Attaches to a running Job using the JobID.
|
static JobListeningContext |
JobClient.submitJob(akka.actor.ActorSystem actorSystem,
Configuration config,
HighAvailabilityServices highAvailabilityServices,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates,
ClassLoader classLoader)
Submits a job to a Flink cluster (non-blocking) and returns a JobListeningContext which can be
passed to
awaitJobResult to get the result of the submission. |
Modifier and Type | Method and Description |
---|---|
static JobExecutionResult |
JobClient.awaitJobResult(JobListeningContext listeningContext)
Given a JobListeningContext, awaits the result of the job execution that this context is bound to
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.