Hi everyone,
Is there any way how to use monthly calendar window in SQL DSL? Maybe I
miss something but i don't see any way for this. Is that correct? Thanks.
Currently I can create window before running SQL transform and it's just a
basic test so i'm fine with:
collection.apply("monthly-window", Window.into(CalendarWindows.months(1)))
.apply(SqlTransform.query("<my query>"));
During my tests I also find probably one bug in SQL windowing (filed
BEAM-6632 [1]) and provide PR [2] with fix and related testCase. It will be
nice if someone can take a look on that PR.
Regards,
Lukas
---
[1] https://issues.apache.org/jira/browse/BEAM-6632
[2] https://github.com/apache/beam/pull/7785