object BloomFilter extends BifrostSerializer[BloomFilter] with Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- BloomFilter
- Serializable
- BifrostSerializer
- Serializer
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- type BloomTopic = Array[Byte] with Tag[Array[Byte], BloomFilter.BloomTopic.Tag]
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply(topics: Set[BloomTopic]): BloomFilter
Create a new Bloom filter given a sequence of topics to be hashed
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- val empty: BloomFilter
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- implicit val jsonDecoder: Decoder[BloomFilter]
- implicit val jsonEncoder: Encoder[BloomFilter]
- implicit val jsonKeyDecoder: KeyDecoder[BloomFilter]
- implicit val jsonKeyEncoder: KeyEncoder[BloomFilter]
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val numBytes: Int
- def parse(r: Reader): BloomFilter
- Definition Classes
- BloomFilter → Serializer
- def parseByteString(byteString: ByteString): BloomFilter
- Definition Classes
- BifrostSerializer
- def parseByteStringTry(byteString: ByteString): Try[BloomFilter]
- Definition Classes
- BifrostSerializer
- def parseBytes(bytes: Array[Byte]): Try[BloomFilter]
- Definition Classes
- BifrostSerializer
- def parseTry(r: Reader): Try[BloomFilter]
- Definition Classes
- Serializer
- def serialize(obj: BloomFilter, w: Writer): Unit
- Definition Classes
- BloomFilter → Serializer
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toByteString(obj: BloomFilter): ByteString
- Definition Classes
- BifrostSerializer
- def toBytes(obj: BloomFilter): Array[Byte]
- Definition Classes
- BifrostSerializer
- def toString(): String
- Definition Classes
- AnyRef → Any
- def update(inputBF: BloomFilter, topics: Set[BloomTopic]): BloomFilter
Returns a new Bloom filter with updated topics included in the bit array.
Returns a new Bloom filter with updated topics included in the bit array. The updated bloom filter computes the indices to be flipped and merges these changes with the input array of longs before returning a new filter
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- object BloomTopic extends TaggedType[Array[Byte]]
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated