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

Class DynamicFilteringDependencyProcessor

java.lang.Object

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

All Implemented Interfaces:

ExecNodeGraphProcessor

public class DynamicFilteringDependencyProcessor
extends Object
implements ExecNodeGraphProcessor

This processor future checks each dynamic filter source to see if it is chained with a multiple input operator. If so, we'll set the dependency flag.

NOTE: This processor can be only applied on BatchExecNode DAG.

Constructor Summary

Constructors

Constructor and Description
DynamicFilteringDependencyProcessor()

Method Summary

Modifier and Type	Method and Description
ExecNodeGraph	process(ExecNodeGraph execGraph, ProcessorContext context) Given an ExecNodeGraph, process it and return the result ExecNodeGraph.

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicFilteringDependencyProcessor

public DynamicFilteringDependencyProcessor()

Method Detail

process

public ExecNodeGraph process(ExecNodeGraph execGraph,
                             ProcessorContext context)

Description copied from interface: ExecNodeGraphProcessor

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

Specified by:

process in interface ExecNodeGraphProcessor