object TimeBucketer
Helper for bucketing/slicing a stream of TSEntries in order to be stored as a packed timeseries in Gorilla TSC encoded format.
- Alphabetic
- By Inheritance
- TimeBucketer
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def bucketEntries[T](buckets: Stream[Long], entries: Seq[TSEntry[T]]): Stream[(Long, Seq[TSEntry[T]])]
Bucket the passed entries into sequences of entries that have domains delimited by the given buckets.
Bucket the passed entries into sequences of entries that have domains delimited by the given buckets. Individual entries will be split/trimmed wherever required.
- buckets
generates the bucket boundaries
- entries
entries to be bucketed.
- returns
a stream of (bucket-start, bucket-entries), the last element will be (bucket-start, empty bucket) to define the end of duration
- def bucketEntries[T](entries: Stream[TSEntry[T]], bucketTimestamps: Stream[Long], maxNumberOfEntries: Int): Stream[TSEntry[Stream[TSEntry[T]]]]
Buckets the passed entries into blocks/chunks that have domains delimited by the given bucketTimestamps.
Buckets the passed entries into blocks/chunks that have domains delimited by the given bucketTimestamps. If such a block exceeds the passed maximal number of entries in size then it is further split up into multiple blocks within the bucket timestamp domain.
A block is represented by a TSEntry containing the entries of the block as a stream.
- entries
a stream to bucket
- bucketTimestamps
generate the bucket boundaries
- maxNumberOfEntries
per bock
- returns
a stream of blocks: TSEntry(stream-of-entries)
- def bucketEntriesToTimeSeries[T](buckets: Stream[Long], entries: Seq[TSEntry[T]], builder: => TimeSeriesBuilder[T]): Stream[(Long, TimeSeries[T])]
Bucket the passed entries into time series that have domains delimited by the given buckets.
Bucket the passed entries into time series that have domains delimited by the given buckets. Individual entries will be split/trimmed wherever required.
- buckets
generates the bucket boundaries
- entries
entries to be bucketed.
- builder
that will construct all the resulting timeseries
- returns
a stream of (bucket-start, corresponding-time series)
- def clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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()