Hello Brian, Yes I found that Calcite supports it.
But I do not know whether you can specify time limits like in Flink for the checkpoint barriers. It is confusing unfortunately to understand it fully. Regards Hans-Peter Op ma 24 jan. 2022 om 19:29 schreef Brian Hulette <[email protected]>: > Hi Hans, > > There was a GSoC project to add support for analytic functions (over > clause) in 2020 [1]. Note the jira is still open, I believe because support > was only added for the Calcite dialect and not ZetaSQL. > > Brian > > [1] https://issues.apache.org/jira/browse/BEAM-9198 > > On Sun, Jan 23, 2022 at 10:50 AM HG <[email protected]> wrote: > >> Hello, >> >> Is it possible with BEAM to use the over aggregation like in Flink? >> >> >> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/over-agg/ >> >> Regards Hans >> >
