Class | Description |
---|---|
BloomFilter |
According to Putze et al.'s "Cache-, Hash- and Space-Efficient BloomFilter
Filters", see this paper
for details, the main theory is to construct tiny bucket bloom filters which benefit to
the cpu cache and SIMD opcode.
|
BloomFilterDef | |
RuntimeFilterDef | |
RuntimeFilterReporter |
A reporter to send out the bloom filters to their receivers.
|
RuntimeFilterRouter |
This class manages the RuntimeFilter routing information of the pushed down join predicate
of the partitioned exchange HashJoin.
|
RuntimeFilterSink |
This sink receives the RuntimeFilters from the netty thread,
aggregates them in an async thread, broadcast the final aggregated
one to the RuntimeFilterRecordBatch.
|
RuntimeFilterWritable |
A binary wire transferable representation of the RuntimeFilter which contains
the runtime filter definition and its corresponding data.
|
Copyright © 1970 The Apache Software Foundation. All rights reserved.