Packages

o

io.sqooba.oss.timeseries.validation

TimestampValidator

object TimestampValidator

This object specifies and checks all the different types of constraints that are imposed on timestamps of timeseries. There are two main types of constraints:

  • logical constraints: chronological, increasing order
  • compression constraints: Positivity, and maximal differences. These are (implicitly) given by the Gorilla library but the library itself does no checks. Therefore, we perform them here.
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TimestampValidator
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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. val MaxGap: Long

    Maximal timestamp difference for two consecutive entries in a gorilla compressed series.

    Maximal timestamp difference for two consecutive entries in a gorilla compressed series.

    This is due to the fact that the difference is cast to a Java Integer inside the library.

  5. val MaxGapToBlock: Long

    Maximal timestamp difference between the timestamp in the header of a gorilla array and the first entry's timestamp.

    Maximal timestamp difference between the timestamp in the header of a gorilla array and the first entry's timestamp.

    This is due to the fact that the library uses 27 bits and ZigZag encoding to encode this difference.

  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  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. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  18. def toString(): String
    Definition Classes
    AnyRef → Any
  19. def validate(lastTs: Long, currentTs: Long): Unit

    Validates two consecutive timestamps of a timeseries for logical constraints i.e.

    Validates two consecutive timestamps of a timeseries for logical constraints i.e. chronological order. Throws if constraints are violated.

  20. def validate(seqTs: Seq[Long]): Unit

    Validates a sequence of consecutive timestamps of a timeseries for logical constraints i.e.

    Validates a sequence of consecutive timestamps of a timeseries for logical constraints i.e. chronological order. Throws if constraints are violated.

    seqTs

    a sequence of at least 2 timestamps

  21. def validateGorilla(lastTs: Long, currentTs: Long): Unit

    Validates two consecutive timestamps of a timeseries for logical AND gorilla compression constraints.

    Validates two consecutive timestamps of a timeseries for logical AND gorilla compression constraints. Throws if constraints are violated.

  22. def validateGorilla(seqTs: Seq[Long]): Unit

    Validates a sequence of consecutive timestamps of a timeseries for logical AND gorilla compression constraints.

    Validates a sequence of consecutive timestamps of a timeseries for logical AND gorilla compression constraints. Throws if constraints are violated.

    seqTs

    a sequence of at least 2 timestamps

  23. def validateGorillaFirst(blockTs: Long, firstEntryTs: Long): Unit

    Validates the timestamp written in the header of a gorilla block and the first entry's timestamp of the timeseries.

    Validates the timestamp written in the header of a gorilla block and the first entry's timestamp of the timeseries. Checks for logical AND gorilla compression constraints. Throws if constraints are violated.

  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped