org.apache.flink.table.planner.plan.nodes.exec.processor

Class ProcessorContext

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.processor.ProcessorContext

public class ProcessorContext
extends Object

Context for ExecNodeGraphProcessor to process ExecNodeGraph.

Constructor Summary

Constructors

Constructor and Description
ProcessorContext(PlannerBase planner)

Method Summary

Modifier and Type	Method and Description
PlannerBase	getPlanner() Gets PlannerBase, org.apache.flink.table.planner.delegation.BatchPlanner for batch job. and org.apache.flink.table.planner.delegation.StreamPlanner for stream job.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProcessorContext

public ProcessorContext(PlannerBase planner)

Method Detail

getPlanner

public PlannerBase getPlanner()

Gets PlannerBase, org.apache.flink.table.planner.delegation.BatchPlanner for batch job. and org.apache.flink.table.planner.delegation.StreamPlanner for stream job.