Packages

c

com.criteo.cuttle.timeseries

TimeSeriesContext

case class TimeSeriesContext(start: Instant, end: Instant, backfill: Option[Backfill] = None, projectVersion: String = "") extends SchedulingContext with Product with Serializable

A TimeSeriesContext is passed to Executions initiated by the TimeSeriesScheduler.

start

Start instant of the partition to compute.

end

End instant of the partition to compute.

backfill

If this execution is for a backfill, the Backfill informations are provided.

Source
TimeSeriesScheduler.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TimeSeriesContext
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. SchedulingContext
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TimeSeriesContext(start: Instant, end: Instant, backfill: Option[Backfill] = None, projectVersion: String = "")

    start

    Start instant of the partition to compute.

    end

    End instant of the partition to compute.

    backfill

    If this execution is for a backfill, the Backfill informations are provided.

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 asJson: Json

    Serialize the context information to JSON.

    Serialize the context information to JSON.

    Definition Classes
    TimeSeriesContextSchedulingContext
  6. val backfill: Option[Backfill]
  7. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. def compareTo(other: SchedulingContext): Int

    Compare to another context.

    Compare to another context. In the current design only context of the same types will be compared to each other because a workflow/project is defined for a single Scheduling type.

    Definition Classes
    TimeSeriesContextSchedulingContext
  9. val end: Instant
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  12. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. def logIntoDatabase: doobie.ConnectionIO[String]

    The doobie effect needed to serialize the context to the database.

    The doobie effect needed to serialize the context to the database.

    Definition Classes
    TimeSeriesContextSchedulingContext
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  18. val projectVersion: String
  19. val start: Instant
  20. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  21. def toId: String
  22. def toInterval: Interval[Instant]
  23. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from SchedulingContext

Inherited from AnyRef

Inherited from Any

Ungrouped