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

Class RuntimeFilterWritable

java.lang.Object

org.apache.drill.exec.work.filter.RuntimeFilterWritable

All Implemented Interfaces:

AutoCloseable, AutoCloseables.Closeable

public class RuntimeFilterWritable
extends Object
implements AutoCloseables.Closeable

A binary wire transferable representation of the RuntimeFilter which contains the runtime filter definition and its corresponding data.

Constructor Summary

Constructors

Constructor	Description
RuntimeFilterWritable(BitData.RuntimeFilterBDef runtimeFilterBDef, DrillBuf... data)

Method Summary

Modifier and Type	Method	Description
void	aggregate(RuntimeFilterWritable runtimeFilterWritable)
void	close()
RuntimeFilterWritable	duplicate(BufferAllocator bufferAllocator)
boolean	equals(Object other)
DrillBuf[]	getData()
BitData.RuntimeFilterBDef	getRuntimeFilterBDef()
int	hashCode()
RuntimeFilterWritable	newRuntimeFilterWritable(BufferAllocator bufferAllocator)
void	retainBuffers(int increment)
void	setData(DrillBuf... data)
String	toString()
List<BloomFilter>	unwrap()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

RuntimeFilterWritable

public RuntimeFilterWritable(BitData.RuntimeFilterBDef runtimeFilterBDef,
 DrillBuf... data)

Method Details

getRuntimeFilterBDef

public BitData.RuntimeFilterBDef getRuntimeFilterBDef()

getData

public DrillBuf[] getData()

setData

public void setData(DrillBuf... data)

unwrap

public List<BloomFilter> unwrap()

aggregate

public void aggregate(RuntimeFilterWritable runtimeFilterWritable)

duplicate

public RuntimeFilterWritable duplicate(BufferAllocator bufferAllocator)

retainBuffers

public void retainBuffers(int increment)

newRuntimeFilterWritable

public RuntimeFilterWritable newRuntimeFilterWritable(BufferAllocator bufferAllocator)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface AutoCloseables.Closeable