Details
-
Improvement
-
Status: Closed
-
Critical
-
Resolution: Implemented
-
1.3.0
-
None
Description
Multiple consecutive windows on batch are not tested yet and I think they are also not supported, because the syntax is not defined for batch yet.
The following should be supported:
val t = table .window(Tumble over 2.millis on 'rowtime as 'w) .groupBy('w) .select('w.rowtime as 'rowtime, 'int.count as 'int) .window(Tumble over 4.millis on 'rowtime as 'w2) .groupBy('w2) .select('w2.rowtime, 'w2.end, 'int.count)
Attachments
Issue Links
- links to