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

Class RuntimeFilterReporter

java.lang.Object

org.apache.drill.exec.work.filter.RuntimeFilterReporter

public class RuntimeFilterReporter
extends Object

A reporter to send out the bloom filters to their receivers.

Constructor Summary

Constructors

Constructor	Description
RuntimeFilterReporter(ExecutorFragmentContext context)

Method Summary

Modifier and Type	Method	Description
void	sendOut(List<BloomFilter> bloomFilters, List<String> probeFields, RuntimeFilterDef runtimeFilterDef, int hashJoinOpId)

Methods inherited from class java.lang.Object

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

Constructor Details

RuntimeFilterReporter

public RuntimeFilterReporter(ExecutorFragmentContext context)

Method Details

sendOut

public void sendOut(List<BloomFilter> bloomFilters,
 List<String> probeFields,
 RuntimeFilterDef runtimeFilterDef,
 int hashJoinOpId)