Package org.apache.drill.exec.work.filter

Class RuntimeFilterSink

java.lang.Object

org.apache.drill.exec.work.filter.RuntimeFilterSink

All Implemented Interfaces:

Closeable, AutoCloseable

public class RuntimeFilterSink
extends Object
implements Closeable

This sink receives the RuntimeFilters from the netty thread, aggregates them in an async thread, broadcast the final aggregated one to the RuntimeFilterRecordBatch.

Constructor Summary

Constructors

Constructor	Description
RuntimeFilterSink(DrillbitContext drillbitContext, SendingAccountor sendingAccountor)

Method Summary

Modifier and Type	Method	Description
void	add(RuntimeFilterWritable runtimeFilterWritable)
void	close()
void	setJoinMjId2probeScanEps(Map<Integer,List<CoordinationProtos.DrillbitEndpoint>> joinMjId2probeScanEps)
void	setJoinMjId2rfNumber(Map<Integer,Integer> joinMjId2rfNumber)
void	setJoinMjId2ScanMjId(Map<Integer,Integer> joinMjId2ScanMjId)

Methods inherited from class java.lang.Object

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

Constructor Details

RuntimeFilterSink

public RuntimeFilterSink(DrillbitContext drillbitContext,
 SendingAccountor sendingAccountor)

Method Details

add

public void add(RuntimeFilterWritable runtimeFilterWritable)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

setJoinMjId2rfNumber

public void setJoinMjId2rfNumber(Map<Integer,Integer> joinMjId2rfNumber)

setJoinMjId2probeScanEps

public void setJoinMjId2probeScanEps(Map<Integer,List<CoordinationProtos.DrillbitEndpoint>> joinMjId2probeScanEps)

setJoinMjId2ScanMjId

public void setJoinMjId2ScanMjId(Map<Integer,Integer> joinMjId2ScanMjId)