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 | Field and Description |
---|---|
protected JobExecutionResult |
ClusterClient.lastJobExecutionResult
For interactive invocations, the job results are only available after the ContextEnvironment has
been run inside the user JAR.
|
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) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
SerializedJobExecutionResult.toJobExecutionResult(ClassLoader loader) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
JobResult.toJobExecutionResult(ClassLoader classLoader)
Converts the
JobResult to a JobExecutionResult . |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
MiniCluster.executeJobBlocking(JobGraph job)
This method runs a job in blocking mode.
|
JobExecutionResult |
JobExecutor.executeJobBlocking(JobGraph jobGraph)
Run the given job and block until its execution result can be returned.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutionEnvironment.execute()
Triggers the program execution.
|
JobExecutionResult |
StreamPlanEnvironment.execute() |
abstract JobExecutionResult |
StreamExecutionEnvironment.execute(StreamGraph streamGraph)
Triggers the program execution.
|
JobExecutionResult |
LocalStreamEnvironment.execute(StreamGraph streamGraph)
Executes the JobGraph of the on a mini cluster of ClusterUtil with a user
specified name.
|
JobExecutionResult |
StreamPlanEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
StreamContextEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
RemoteStreamEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
StreamExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
static JobExecutionResult |
RemoteStreamEnvironment.executeRemotely(StreamExecutionEnvironment streamExecutionEnvironment,
List<URL> jarFiles,
String host,
int port,
Configuration clientConfiguration,
List<URL> globalClasspaths,
String jobName,
SavepointRestoreSettings savepointRestoreSettings)
Executes the job remotely.
|
protected JobExecutionResult |
RemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph,
List<URL> jarFiles)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TestStreamEnvironment.execute(StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TableEnvironment.execute(String jobName)
Triggers the program execution.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TableEnvironmentImpl.execute(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamTableEnvironment.execute(String jobName)
Triggers the program execution.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ProgramDeployer.fetchExecutionResult() |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
Executor.execute(String jobName)
Executes all the previously applied transformations via
Executor.apply(List) . |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutor.execute(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutor.execute(String jobName) |
JobExecutionResult |
BatchExecutor.execute(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
DummyStreamExecutionEnvironment.execute() |
JobExecutionResult |
DummyStreamExecutionEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
DummyStreamExecutionEnvironment.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–2020 The Apache Software Foundation. All rights reserved.