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 and Description
RuntimeFilterReporter(ExecutorFragmentContext context)

Method Summary

Modifier and Type	Method and 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 Detail

RuntimeFilterReporter

public RuntimeFilterReporter(ExecutorFragmentContext context)

Method Detail

sendOut

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