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

接口 ExecNodeGraphProcessor

所有已知实现类:

DeadlockBreakupProcessor, ForwardHashExchangeProcessor, MultipleInputNodeCreationProcessor

public interface ExecNodeGraphProcessor

ExecNodeGraphProcessor plugin, use it can change or update the given ExecNodeGraph.

方法概要

限定符和类型	方法和说明
ExecNodeGraph	process(ExecNodeGraph execGraph, ProcessorContext context) Given an ExecNodeGraph, process it and return the result ExecNodeGraph.

方法详细资料

process

ExecNodeGraph process(ExecNodeGraph execGraph,
                      ProcessorContext context)

Given an ExecNodeGraph, process it and return the result ExecNodeGraph.