Your approach is right. The SQL query will be applied to each window.
Thanks for the report & fix of the bug, too!
Kenn
On Fri, Feb 8, 2019 at 7:32 AM Lukáš Drbal <lukas.dr...@gmail.com> wrote:
> 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
>
