FlinkFormula

case class SlidingTimeWindows(size: org.apache.flink.streaming.api.windowing.time.Time, slide: 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
implicit class SplitterMissingFlinkFormula[T] extends Serializable
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
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

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 clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): 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[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
implicit def timedElemOrdering[T](implicit arg0: Ordering[T]): Ordering[TimedElement[T]]
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )