RuntimeFilterRouter (Drill : 1.20.3 API)

```
public class RuntimeFilterRouter
extends Object
```
This class manages the RuntimeFilter routing information of the pushed down join predicate of the partitioned exchange HashJoin. The working flow of the RuntimeFilter has two kinds: Broadcast case and Partitioned case. The HashJoinRecordBatch is responsible to generate the RuntimeFilter. To Partitioned case: The generated RuntimeFilter will be sent to the Foreman node. The Foreman node receives the RuntimeFilter async, broadcasts them to the Scan nodes's MinorFragment. The RuntimeFilterRecordBatch which is downstream to the Scan node will aggregate all the received RuntimeFilter and will leverage it to filter out the scanned rows to generate the SV2. To Broadcast case: The generated RuntimeFilter will be sent to Scan node's RuntimeFilterRecordBatch directly. The working of the RuntimeFilterRecordBath is the same as the Partitioned one.

Nested Classes
Modifier and Type	Class and Description
`protected class`	`RuntimeFilterRouter.RuntimeFilterParallelismCollector` Collect the runtime filter parallelism related information such as join node major/minor fragment id , probe side scan node's major/minor fragment id, probe side node's endpoints.

Constructors
Constructor and Description
`RuntimeFilterRouter(QueryWorkUnit workUnit, DrillbitContext drillbitContext)` This class maintains context for the runtime join push down's filter management.

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`collectRuntimeFilterParallelAndControlInfo()` This method is to collect the parallel information of the RuntimetimeFilters.
`void`	`register(RuntimeFilterWritable srcRuntimeFilterWritable)` This method is passively invoked by receiving a runtime filter from the network
`void`	`waitForComplete()`

Class RuntimeFilterRouter