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.
A reporter to send out the bloom filters to their receivers.
This class manages the RuntimeFilter routing information of the pushed down join predicate of the partitioned exchange HashJoin.
This sink receives the RuntimeFilters from the netty thread, aggregates them in an async thread, broadcast the final aggregated one to the RuntimeFilterRecordBatch.
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.