Modifier and Type | Method and Description |
---|---|
abstract JobExecutionResult |
PlanExecutor.executePlan(Plan plan)
Execute the given program.
|
static JobExecutionResult |
JobExecutionResult.fromJobSubmissionResult(JobSubmissionResult result)
Returns a dummy object for wrapping a JobSubmissionResult
|
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 |
RemoteEnvironment.execute(String jobName) |
JobExecutionResult |
LocalEnvironment.execute(String jobName) |
abstract JobExecutionResult |
ExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
JobExecutionResult |
CollectionEnvironment.execute(String jobName) |
JobExecutionResult |
ScalaShellRemoteEnvironment.execute(String jobName)
compiles jars from files in the shell virtual directory on the fly, sends and executes it in the remote environment
|
JobExecutionResult |
ExecutionEnvironment.getLastJobExecutionResult()
Returns the
JobExecutionResult of the last executed job. |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ExecutionEnvironment.execute()
Triggers the program execution.
|
JobExecutionResult |
ExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
JobExecutionResult |
ExecutionEnvironment.getLastJobExecutionResult()
Gets 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 |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
PreviewPlanEnvironment.execute(String jobName) |
JobExecutionResult |
OptimizerPlanEnvironment.execute(String jobName) |
JobExecutionResult |
DetachedEnvironment.execute(String jobName) |
JobExecutionResult |
ContextEnvironment.execute(String jobName) |
JobExecutionResult |
Client.runBlocking(FlinkPlan compiledPlan,
List<URL> libraries,
List<URL> classpaths,
ClassLoader classLoader) |
JobExecutionResult |
Client.runBlocking(FlinkPlan compiledPlan,
List<URL> libraries,
List<URL> classpaths,
ClassLoader classLoader,
String savepointPath) |
JobExecutionResult |
Client.runBlocking(JobGraph jobGraph,
ClassLoader classLoader) |
JobExecutionResult |
Client.runBlocking(JobWithJars program,
int parallelism) |
JobExecutionResult |
Client.runBlocking(JobWithJars program,
int parallelism,
String savepointPath)
Runs a program on the Flink cluster to which this client is connected.
|
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.
|
JobExecutionResult |
SerializedJobExecutionResult.toJobExecutionResult(ClassLoader loader) |
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) |
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 |
StreamPlanEnvironment.execute() |
JobExecutionResult |
StreamExecutionEnvironment.execute()
Triggers the program execution.
|
JobExecutionResult |
StreamPlanEnvironment.execute(String jobName) |
abstract JobExecutionResult |
StreamExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
JobExecutionResult |
StreamContextEnvironment.execute(String jobName) |
JobExecutionResult |
RemoteStreamEnvironment.execute(String jobName) |
JobExecutionResult |
LocalStreamEnvironment.execute(String jobName)
Executes the JobGraph of the on a mini cluster of CLusterUtil with a user
specified name.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutionEnvironment.execute()
Triggers the program execution.
|
JobExecutionResult |
StreamExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
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–2017 The Apache Software Foundation. All rights reserved.