Class ExecutionPlanJSONGenerator
- java.lang.Object
-
- org.apache.flink.optimizer.plandump.ExecutionPlanJSONGenerator
-
- All Implemented Interfaces:
org.apache.flink.api.java.ExecutionPlanUtil.ExecutionPlanJSONGenerator
public class ExecutionPlanJSONGenerator extends Object implements org.apache.flink.api.java.ExecutionPlanUtil.ExecutionPlanJSONGenerator
Utility for extracting an execution plan (as JSON) from a givenPlan.We need this util here in the optimizer because it is the only module that has
Optimizer,OptimizedPlan, andPlanJSONDumpGeneratoravailable. We use this reflectively from the batch execution environments to generate the plan, which we cannot do there. It is used fromExecutionPlanUtil.
-
-
Constructor Summary
Constructors Constructor Description ExecutionPlanJSONGenerator()
-
-
-
Method Detail
-
getExecutionPlan
public String getExecutionPlan(org.apache.flink.api.common.Plan plan)
- Specified by:
getExecutionPlanin interfaceorg.apache.flink.api.java.ExecutionPlanUtil.ExecutionPlanJSONGenerator
-
-