Package | Description |
---|---|
org.apache.flink.optimizer.plan |
Modifier and Type | Method and Description |
---|---|
Collection<SourcePlanNode> |
OptimizedPlan.getDataSources()
Gets the data sources from this OptimizedPlan.
|
Constructor and Description |
---|
OptimizedPlan(Collection<SourcePlanNode> sources,
Collection<SinkPlanNode> sinks,
Collection<PlanNode> allNodes,
String jobName,
Plan programPlan)
Creates a new instance of this optimizer plan container.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.