Modifier and Type | Method and Description |
---|---|
abstract JobExecutionResult |
PlanExecutor.executePlan(Plan plan)
Execute the given program.
|
static JobExecutionResult |
JobExecutionResult.fromJobSubmissionResult(JobSubmissionResult result)
Deprecated.
Will be removed in future versions.
|
JobExecutionResult |
JobSubmissionResult.getJobExecutionResult()
Returns the JobExecutionResult if available.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
CollectionExecutor.execute(Plan program) |
Modifier and Type | Field and Description |
---|---|
protected JobExecutionResult |
ExecutionEnvironment.lastJobExecutionResult
Result from the latest execution, to make it retrievable when using eager execution methods.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ExecutionEnvironment.execute()
Triggers the program execution.
|
JobExecutionResult |
CollectionEnvironment.execute(String jobName) |
JobExecutionResult |
RemoteEnvironment.execute(String jobName) |
abstract JobExecutionResult |
ExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
JobExecutionResult |
LocalEnvironment.execute(String jobName) |
protected JobExecutionResult |
ScalaShellRemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph,
List<URL> jarFiles)
Executes the remote job.
|
JobExecutionResult |
ExecutionEnvironment.getLastJobExecutionResult()
Returns the
JobExecutionResult of the last executed job. |
Modifier and Type | Method and Description |
---|---|
static JobExecutionResult |
LocalExecutor.execute(Plan plan)
Executes the given dataflow plan.
|
static JobExecutionResult |
LocalExecutor.execute(Program pa,
String... args)
Executes the given program.
|
JobExecutionResult |
RemoteExecutor.executePlan(Plan plan) |
JobExecutionResult |
LocalExecutor.executePlan(Plan plan)
Executes the given program on a local runtime and waits for the job to finish.
|
JobExecutionResult |
RemoteExecutor.executePlanWithJars(JobWithJars program) |
Modifier and Type | Class and Description |
---|---|
static class |
DetachedEnvironment.DetachedJobExecutionResult
The
JobExecutionResult returned by a DetachedEnvironment . |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
DetachedEnvironment.execute(String jobName) |
JobExecutionResult |
OptimizerPlanEnvironment.execute(String jobName) |
JobExecutionResult |
PreviewPlanEnvironment.execute(String jobName) |
JobExecutionResult |
ContextEnvironment.execute(String jobName) |
JobExecutionResult |
ClusterClient.retrieveJob(JobID jobID)
Reattaches to a running from from the supplied job id.
|
JobExecutionResult |
ClusterClient.run(JobGraph jobGraph,
ClassLoader classLoader)
Submits a JobGraph blocking.
|
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
|
static JobExecutionResult |
JobClient.submitJobAndWait(akka.actor.ActorSystem actorSystem,
Configuration config,
HighAvailabilityServices highAvailabilityServices,
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.
|
JobExecutionResult |
SerializedJobExecutionResult.toJobExecutionResult(ClassLoader loader) |
Modifier and Type | Method and Description |
---|---|
void |
OnCompletionActions.jobFinished(JobExecutionResult result) |
Modifier and Type | Method and Description |
---|---|
void |
JobManagerRunner.jobFinished(JobExecutionResult result)
Job completion notification triggered by JobManager.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
MiniCluster.runJobBlocking(JobGraph job)
This method runs a job in blocking mode.
|
JobExecutionResult |
MiniClusterJobDispatcher.runJobBlocking(JobGraph job)
This method runs a job in blocking mode.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
FlinkTopology.execute()
Directly executes the Storm topology based on the current context (local when in IDE and
remote when executed through ./bin/flink).
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutionEnvironment.execute()
Triggers the program execution.
|
JobExecutionResult |
StreamPlanEnvironment.execute() |
abstract JobExecutionResult |
StreamExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
JobExecutionResult |
Flip6LocalStreamEnvironment.execute(String jobName)
Executes the JobGraph of the on a mini cluster of CLusterUtil with a user
specified name.
|
JobExecutionResult |
LocalStreamEnvironment.execute(String jobName)
Executes the JobGraph of the on a mini cluster of CLusterUtil with a user
specified name.
|
JobExecutionResult |
StreamPlanEnvironment.execute(String jobName) |
JobExecutionResult |
StreamContextEnvironment.execute(String jobName) |
JobExecutionResult |
RemoteStreamEnvironment.execute(String jobName) |
protected JobExecutionResult |
RemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph,
List<URL> jarFiles)
Executes the remote job.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TestStreamEnvironment.execute(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
CollectionTestEnvironment.execute() |
JobExecutionResult |
TestEnvironment.execute(String jobName) |
JobExecutionResult |
CollectionTestEnvironment.execute(String jobName) |
JobExecutionResult |
TestEnvironment.getLastJobExecutionResult() |
JobExecutionResult |
CollectionTestEnvironment.getLastJobExecutionResult() |
JobExecutionResult |
JavaProgramTestBase.getLatestExecutionResult() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.