Uses of Class
org.apache.flink.optimizer.plan.OptimizedPlan
-
Packages that use OptimizedPlan Package Description org.apache.flink.optimizer org.apache.flink.optimizer.plandump org.apache.flink.optimizer.plantranslate org.apache.flink.optimizer.postpass org.apache.flink.optimizer.traversals This package contains the various traversals over the program plan and the optimizer DAG (directed acyclic graph) that are made in the course of the optimization. -
-
Uses of OptimizedPlan in org.apache.flink.optimizer
Methods in org.apache.flink.optimizer that return OptimizedPlan Modifier and Type Method Description OptimizedPlanOptimizer. compile(org.apache.flink.api.common.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. -
Uses of OptimizedPlan in org.apache.flink.optimizer.plandump
Methods in org.apache.flink.optimizer.plandump with parameters of type OptimizedPlan Modifier and Type Method Description voidPlanJSONDumpGenerator. dumpOptimizerPlanAsJSON(OptimizedPlan plan, File toFile)voidPlanJSONDumpGenerator. dumpOptimizerPlanAsJSON(OptimizedPlan plan, PrintWriter writer)StringPlanJSONDumpGenerator. getOptimizerPlanAsJSON(OptimizedPlan plan) -
Uses of OptimizedPlan in org.apache.flink.optimizer.plantranslate
Methods in org.apache.flink.optimizer.plantranslate with parameters of type OptimizedPlan Modifier and Type Method Description org.apache.flink.runtime.jobgraph.JobGraphJobGraphGenerator. compileJobGraph(OptimizedPlan program)Translates aOptimizedPlaninto aJobGraph.org.apache.flink.runtime.jobgraph.JobGraphJobGraphGenerator. compileJobGraph(OptimizedPlan program, org.apache.flink.api.common.JobID jobId) -
Uses of OptimizedPlan in org.apache.flink.optimizer.postpass
Methods in org.apache.flink.optimizer.postpass with parameters of type OptimizedPlan Modifier and Type Method Description voidJavaApiPostPass. postPass(OptimizedPlan plan)voidOptimizerPostPass. postPass(OptimizedPlan plan)Central post processing function. -
Uses of OptimizedPlan in org.apache.flink.optimizer.traversals
Methods in org.apache.flink.optimizer.traversals that return OptimizedPlan Modifier and Type Method Description OptimizedPlanPlanFinalizer. createFinalPlan(List<SinkPlanNode> sinks, String jobName, org.apache.flink.api.common.Plan originalPlan)Constructors in org.apache.flink.optimizer.traversals with parameters of type OptimizedPlan Constructor Description RangePartitionRewriter(OptimizedPlan plan)
-