...
WINDOW
Description
Parameter
size:The size of the windowadvance:The advance the window moves forwardslide:The slide of the windowtype:The type of the window. The possible values are Time, Tuple, and Unboundpartition:The partition attribute of the windowstartCondition:The start condition for a predicate windowendCondition:The end condition for a predicate window
Example
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
//sliding time |
...
window output = window({size = 5, advance = 1, type = 'time'}, |
...
input) //sliding tuple window partioniert ueber |
...
bidder output = window({size = 5, advance = 1, type = 'tuple', partition=['bidder']}, |
...
input) //unbounded |
...
window output = window({type = 'unbounded'}, |
...
input) //now window (size = 1, advance = 1) |
...
output = window({type = 'time'}, |
...
input) //sliding delta window, reduces time granularity to value of |
...
slide output = window({size = 5, type = 'time', slide = 5}, |
...
input) // Predicate |
...
window output = window({startCondition=RelationalPredicate('a>10'), endCondition = RelationalPredicate('a<10')}, |
...
input) |
Benchmark
BATCHPRODUCER
Description
...