BinaryUnionReplacer (Flink : Optimizer 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.optimizer.traversals.BinaryUnionReplacer

All Implemented Interfaces:

org.apache.flink.util.Visitor<PlanNode>
```
public class BinaryUnionReplacer
extends Object
implements org.apache.flink.util.Visitor<PlanNode>
```
A traversal that collects cascading binary unions into a single n-ary union operator. The exception is, when on of the union inputs is materialized, such as in the static-code-path-cache in iterations.

Constructor Summary

Constructors
Constructor Description

BinaryUnionReplacer()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`collect(Channel in, List<Channel> inputs)`
`void`	`postVisit(PlanNode visitable)`
`boolean`	`preVisit(PlanNode visitable)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- BinaryUnionReplacer
```
public BinaryUnionReplacer()
```

Method Detail

preVisit
```
public boolean preVisit(PlanNode visitable)
```
Specified by:

preVisit in interface org.apache.flink.util.Visitor<PlanNode>

postVisit
```
public void postVisit(PlanNode visitable)
```
Specified by:

postVisit in interface org.apache.flink.util.Visitor<PlanNode>

collect

public void collect(Channel in,
                    List<Channel> inputs)