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

package org.apache.drill.exec.work.filter
  • Classes
    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.