Class 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 given Plan.

    We need this util here in the optimizer because it is the only module that has Optimizer, OptimizedPlan, and PlanJSONDumpGenerator available. We use this reflectively from the batch execution environments to generate the plan, which we cannot do there. It is used from ExecutionPlanUtil.

    • Constructor Detail

      • ExecutionPlanJSONGenerator

        public ExecutionPlanJSONGenerator()
    • Method Detail

      • getExecutionPlan

        public String getExecutionPlan​(org.apache.flink.api.common.Plan plan)
        Specified by:
        getExecutionPlan in interface org.apache.flink.api.java.ExecutionPlanUtil.ExecutionPlanJSONGenerator