Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.optimizer | |
org.apache.flink.optimizer.dag |
Modifier and Type | Method and Description |
---|---|
static FlinkPlan |
Client.getOptimizedPlan(Optimizer compiler,
PackagedProgram prog,
int parallelism) |
static OptimizedPlan |
Client.getOptimizedPlan(Optimizer compiler,
Plan p,
int parallelism) |
static String |
Client.getOptimizedPlanAsJson(Optimizer compiler,
PackagedProgram prog,
int parallelism) |
JobExecutionResult |
Client.runBlocking(JobWithJars program,
int parallelism,
String savepointPath)
Runs a program on the Flink cluster to which this client is connected.
|
JobSubmissionResult |
Client.runDetached(JobWithJars program,
int parallelism,
String savepointPath)
Submits a program to the Flink cluster to which this client is connected.
|
Modifier and Type | Class and Description |
---|---|
class |
CompilerPostPassException
An exception that is thrown by the Optimizer when encountering
a problem during the optimizer post pass.
|
Modifier and Type | Method and Description |
---|---|
OptimizedPlan |
Optimizer.compile(Plan program)
Translates the given program to an OptimizedPlan, where all nodes have their local strategy assigned
and all channels have a shipping strategy assigned.
|
Modifier and Type | Method and Description |
---|---|
void |
SingleInputNode.setInput(Map<Operator<?>,OptimizerNode> contractToNode,
ExecutionMode defaultExchangeMode) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.