Package org.apache.flink.table.runtime.operators.runtimefilter.util

Class RuntimeFilterUtils

java.lang.Object

org.apache.flink.table.runtime.operators.runtimefilter.util.RuntimeFilterUtils

public class RuntimeFilterUtils
extends Object

Utilities for runtime filter.

Field Summary

Fields

Modifier and Type	Field	Description
static int	OVER_MAX_ROW_COUNT

Constructor Summary

Constructors

Constructor	Description
RuntimeFilterUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.table.data.RowData	convertBloomFilterToRowData(int actualRowCount, byte[] serializedBloomFilter)
static org.apache.flink.table.data.RowData	convertBloomFilterToRowData(int actualRowCount, org.apache.flink.runtime.operators.util.BloomFilter bloomFilter)
static org.apache.flink.runtime.operators.util.BloomFilter	createOnHeapBloomFilter(int numExpectedEntries)

Methods inherited from class java.lang.Object

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

Field Detail

OVER_MAX_ROW_COUNT

public static final int OVER_MAX_ROW_COUNT

See Also:

Constant Field Values

Constructor Detail

RuntimeFilterUtils

public RuntimeFilterUtils()

Method Detail

createOnHeapBloomFilter

public static org.apache.flink.runtime.operators.util.BloomFilter createOnHeapBloomFilter(int numExpectedEntries)

convertBloomFilterToRowData

public static org.apache.flink.table.data.RowData convertBloomFilterToRowData(int actualRowCount,
                                                                              @Nullable
                                                                              org.apache.flink.runtime.operators.util.BloomFilter bloomFilter)

convertBloomFilterToRowData

public static org.apache.flink.table.data.RowData convertBloomFilterToRowData(int actualRowCount,
                                                                              @Nullable
                                                                              byte[] serializedBloomFilter)