case class HLLSeries(bits: Int, rows: Vector[Map[Int, Long]]) extends Product with Serializable
HLLSeries can produce a HyperLogLog counter for any window into the past, using a constant factor more space than HyperLogLog.
For each hash bucket, rather than keeping a single max RhoW value, it keeps every RhoW value it has seen, and the max timestamp where it saw that value. This allows it to reconstruct an HLL as it would be had it started at zero at any given point in the past, and seen the same updates this structure has seen.
- bits
The number of bits to use
- rows
Vector of maps of RhoW -> max timestamp where it was seen
- returns
New HLLSeries
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- HLLSeries
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new HLLSeries(bits: Int, rows: Vector[Map[Int, Long]])
- bits
The number of bits to use
- rows
Vector of maps of RhoW -> max timestamp where it was seen
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 approximateSizeSince(threshold: Long): Approximate[Long]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val bits: Int
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def insert(data: Array[Byte], timestamp: Long): HLLSeries
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def maxRhowStats(threshold: Long): (Int, Double)
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val rows: Vector[Map[Int, Long]]
- def since(threshold: Long): HLLSeries
- returns
New HLLSeries only including RhoWs for values seen at or after the given timestamp
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toHLL: HLL
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()