Packages

case class MutableScalableBloomFilter[T](fpProb: Double, headCapacity: Long, growthRate: Int, tighteningRatio: Double, headFPProb: Double, headCount: Long, head: Option[google.common.hash.BloomFilter[T]], tail: List[Either[google.common.hash.BloomFilter[T], SerializedBloomFilters]])(implicit funnel: Funnel[T]) extends Serializable with Product

Import magnolify.guava.auto._ to get common instances of Guava Funnel s.

T

The type of objects inserted into the filter

fpProb

The initial false positive probability

headCapacity

The capacity of the filter at the head of filters

growthRate

The growth rate of each subsequent filter added to filters

tighteningRatio

The tightening ratio applied to headFPProb when scaling

headFPProb

The false positive probability of the head of filters

headCount

The number of items currently in the filter at the head of filters

head

The underlying bloom filter currently being inserted into, or None if this scalable filter has just been initialized

tail

The underlying already-saturated bloom filters, lazily deserialized from bytes as necessary.

funnel

The funnel to turn Ts into bytes

Source
MutableScalableBloomFilter.scala
Linear Supertypes
Product, Equals, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MutableScalableBloomFilter
  2. Product
  3. Equals
  4. Serializable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new MutableScalableBloomFilter(fpProb: Double, headCapacity: Long, growthRate: Int, tighteningRatio: Double, headFPProb: Double, headCount: Long, head: Option[google.common.hash.BloomFilter[T]], tail: List[Either[google.common.hash.BloomFilter[T], SerializedBloomFilters]])(implicit funnel: Funnel[T])

    fpProb

    The initial false positive probability

    headCapacity

    The capacity of the filter at the head of filters

    growthRate

    The growth rate of each subsequent filter added to filters

    tighteningRatio

    The tightening ratio applied to headFPProb when scaling

    headFPProb

    The false positive probability of the head of filters

    headCount

    The number of items currently in the filter at the head of filters

    head

    The underlying bloom filter currently being inserted into, or None if this scalable filter has just been initialized

    tail

    The underlying already-saturated bloom filters, lazily deserialized from bytes as necessary.

    funnel

    The funnel to turn Ts into bytes

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. def ++=(items: TraversableOnce[T]): MutableScalableBloomFilter[T]
  4. def +=(item: T): MutableScalableBloomFilter[T]
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. def approximateElementCount: Long

    Note: Will cause deserialization of any SerializedBloomFilters.

    Note: Will cause deserialization of any SerializedBloomFilters.

    returns

    The sum of the approximate element count for all underlying filters.

  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  11. val fpProb: Double
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. def mightContain(item: T): Boolean

    Note: Will cause deserialization of any SerializedBloomFilters.

    Note: Will cause deserialization of any SerializedBloomFilters.

    item

    The item to check

    returns

    True if any of the backing filters 'might contain' item, false otherwise.

  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. def productElementNames: Iterator[String]
    Definition Classes
    Product
  19. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from Product

Inherited from Equals

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped