Page History

...

• 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. The tuple for which this condition is evaluated to true is only part of the result, if keepEndingElement is set to true!
• clear: If this parameter is set, the window will only be cleared, if the condition is true. By this, the same element can be part of multiple windows (sliding)
• sameStartTime: If set to true, all produced elements get the same start timestamp
• size: The maximum size of the window. Can be either a single number or a pair of a number and a time unit. Possible values for the unit are one of TimeUnit like SECONDS, NANOSECODS etc. - default time is the base time of the stream (typically milliseconds)

• keepEndingElement: Typically, the object that fulfils the end condition will not be part of the result. If setting this attribute to true, the element will be part

• partition: Evaluate the predicates on partitioned defined by different values of this attribute (similar to group by in aggreation)

• useElementOnlyForStartOrEnd: Typically, an object is used to evaluate the start and the end condition and an element can be used for both and can be part of multiple windows, i.e. the same element can be used to close a window and open a new window. If set to true, only the start or end predicate will be evaluted, i.e. an element cannot be used to close an open window and use the same element to open a new window.
• keepTimeOrder: If set to false, the ouput generation does not care about order. Typically, this makes only sense when using nesting=true!
• closeWindowWithHeartbeat: if true, the window is closed when a heartbeat is received. Take a look at the session window to see how it works.
• closeWindowAfterNoupdatesFor: A time parameter by which the window could be closed if some time no new element reaches the buffer. Mostly makes sense for partioned windows but works also with heartbeats.
• closeWindowAfterNoUpdateTimePort: In cases, the window closes because of closeWindowAfterNoUpdateTime this port is used for the output. Default is 0, i.e. the default output port. This can be used to handle outputs of this kind differently.
• nesting: Default false. If set to true, elements that are grouped together are written in a single object as list.

Parameters for MaxWindowTime

...