Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.optimizer | |
org.apache.flink.optimizer.dag |
Modifier and Type | Method and Description |
---|---|
static Pipeline |
PackagedProgramUtils.getPipelineFromProgram(PackagedProgram program,
Configuration configuration,
int parallelism,
boolean suppressOutput) |
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–2024 The Apache Software Foundation. All rights reserved.