Class

es.ucm.fdi.sscheck.prop.tl.flink.FlinkFormula

TumblingTimeWindows

Related Doc: package FlinkFormula

Permalink

case class TumblingTimeWindows(size: org.apache.flink.streaming.api.windowing.time.Time, startTime: org.apache.flink.streaming.api.windowing.time.Time = Time.milliseconds(0)) extends StreamDiscretizer with Product with Serializable

Split data as a series of tumbling windows of size windowSize and starting at startTime

startTime

Start time of the first window. Note, as windows can be empty, we do NOT require to have at least one element in data with that time stamp

Linear Supertypes
Serializable, Serializable, Product, Equals, StreamDiscretizer, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TumblingTimeWindows
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. StreamDiscretizer
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TumblingTimeWindows(size: org.apache.flink.streaming.api.windowing.time.Time, startTime: org.apache.flink.streaming.api.windowing.time.Time = Time.milliseconds(0))

    Permalink

    startTime

    Start time of the first window. Note, as windows can be empty, we do NOT require to have at least one element in data with that time stamp

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  6. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  7. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  8. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  9. def getWindows[T](data: DataSet[TimedElement[T]]): Iterator[TimedWindow[T]]

    Permalink

    data

    data set to split into windows, using the timestamp of TimedElement as time Note: windows are generated until covering the last element. That means that empty windows at the end are ignored. We are not supporting a lastWindowEndTime parameter because that cannot be computed from a TSeq[A] without knowing the windowing criteria, as conceptually a window can extend beyond the timestamp of it's latest element

    Definition Classes
    TumblingTimeWindows → StreamDiscretizer

  10. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  11. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  12. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  13. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  14. val size: org.apache.flink.streaming.api.windowing.time.Time

    Permalink

  15. val startTime: org.apache.flink.streaming.api.windowing.time.Time

    Permalink

    Start time of the first window.

    Start time of the first window. Note, as windows can be empty, we do NOT require to have at least one element in data with that time stamp

  16. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  17. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  18. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  19. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from StreamDiscretizer

Inherited from AnyRef

Inherited from Any

Ungrouped