Page History

WINDOW should no longer be used. Use instead:

ElementWindow

PredicateWindow

SessionWindow

TimeWindow

For special cases the Timestamp operator can be used.

The window sets – dependent on the used parameters – the validity of the tuple. If a time based window is used, the default time granularity is in milliseconds. So, if you have another time granularity, you may use the unit-parameter (e.g. use 5 for size and SECONDS for the unit parameter) or you have to adjust the arity (e.g. use 5000 for size without the unit parameter)

Parameter

• size: The size of the window
• advance: The advance the window moves forward
• slide: The slide of the window. When using this parameter all elements in the windows will have the same starttimestamp (e.g. helful for aggregations), while advance will not change the starttimestamp.
• type: The type of the window. The possible values are Time, Tuple, Predicate, and Unbound
• partition: The partition attribute of the window
• start: The start condition for a predicate window. If the condition evaluates to true, the windows is opened until the end predicate evaluates to true (or if not given the start predicate evaluates to false). Note, that all elements that are not inside a window are send to ouput port 1
• end: The end condition for a predicate window
• sameStartTime: For predicate windows: If set to true, all produced elements get the same start timestamp
• unit: The unit for the time granularity - Possible values are one of TimeUnit like SECONDS, NANOSECODS etc. - default time

Example

...

...