Packages

object GorillaBlock

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GorillaBlock
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class Builder extends AnyRef

    A 'mutable.Builder' for the iterative construction of a GorillaBlock.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. def compress(entries: Stream[TSEntry[Double]]): GorillaBlock

    Compress all the entries of the stream according to the Gorilla TSC format to two GorillaArrays and wrap them in a GorillaBlock.

    Compress all the entries of the stream according to the Gorilla TSC format to two GorillaArrays and wrap them in a GorillaBlock.

    entries

    a non-empty stream of TSEntry[Double] to be compressed, other types of numbers need to be converted to doubles

    returns

    a gorilla encoded block

    Note

    The entries need to be a well-formed series according to TSEntryFitter and TimestampValidator. Those constraints are checked and enforced.

  7. def compressSampled(entries: Stream[TSEntry[Double]], sampleRate: Long): GorillaBlock

    Compress all the entries of the stream according to the Gorilla TSC format to one GorillaArray and wrap it in a GorillaBlock.

    Compress all the entries of the stream according to the Gorilla TSC format to one GorillaArray and wrap it in a GorillaBlock. The sample rate will be written as well.

    entries

    a non-empty stream of TSEntry[Double] to be compressed, their validities will be discarded

    sampleRate

    the fixed validity for all the entries

    returns

    a gorilla encoded block

    Note

    The entries need to be a well-formed series according to TSEntryFitter and TimestampValidator. Those constraints are checked and enforced.

  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  11. def fromSampled(valueBytes: GorillaArray, sampleRate: Long): GorillaBlock

    Create a GorillaBlock from a value GorillaArray and a sample rate.

    Create a GorillaBlock from a value GorillaArray and a sample rate.

    valueBytes

    encodes the timeseries formed by the values along with their timestamps

    sampleRate

    the constant validity of each entry in the series

  12. def fromTupleArrays(valueBytes: GorillaArray, validityBytes: GorillaArray): GorillaBlock

    Create a GorillaBlock from a tuple of GorillaArrays.

    Create a GorillaBlock from a tuple of GorillaArrays.

    valueBytes

    encodes the timeseries formed by the values along with their timestamps

    validityBytes

    encodes the series formed by the validities with their timestamps

  13. def fromTupleSerialized(bytes: Array[Byte]): GorillaBlock

    Deserialize a tuple GorillaBlock according to the binary format specified above and return it.

  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. def newBuilder(fixedValidity: Long, compress: Boolean): Builder

    A 'mutable.Builder' for the iterative construction of a GorillaBlock.

    A 'mutable.Builder' for the iterative construction of a GorillaBlock. The builder takes TSEntries and continually encodes them to a sampled GorillaBlock in which all entries have the validity of the sample rate.

  19. def newBuilder(fixedValidity: Long): Builder

    A 'mutable.Builder' for the iterative construction of a GorillaBlock.

    A 'mutable.Builder' for the iterative construction of a GorillaBlock. The builder takes TSEntries and continually encodes them to a sampled GorillaBlock in which all entries have the validity of the sample rate. This also compresses contiguous equal entries.

  20. def newBuilder(compress: Boolean): Builder

    A 'mutable.Builder' for the iterative construction of a GorillaBlock.

    A 'mutable.Builder' for the iterative construction of a GorillaBlock. The builder takes TSEntries and continually encodes them.

  21. def newBuilder: Builder

    A 'mutable.Builder' for the iterative construction of a GorillaBlock.

    A 'mutable.Builder' for the iterative construction of a GorillaBlock. The builder takes TSEntries and continually encodes them. This also compresses contiguous equal entries.

  22. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  25. def toString(): String
    Definition Classes
    AnyRef → Any
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  28. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped