Thanks Julian. If it's nobody who is currently working on it, I would like to work on it.
I would like to start from adding windowing table functions because I am trying to support it in Apache Beam SQL. Like you said, how will watermark work with these table functions would be an interesting area, which I could explore in BeamSQL. -Rui On Mon, Aug 19, 2019 at 8:55 PM Julian Hyde <jh...@apache.org> wrote: > Calcite has not implemented the syntax in that paper. I would support an > effort to add it (unsurprising, since I am a co-author of that paper). > > EMIT STREAM is equivalent to the current SELECT STREAM syntax. > > There is no equivalent in current Calcite of the EMIT AFTER WATERMARK, or > EMIT STREAM AFTER DELAY. > > HOP, TUMBLE and SESSION are supported in Calcite’s SQL parser, but > following the paper would be replaced with a table function call. We could > need to add HOP, TUMBLE and SESSION table functions. We would also need to > make the system aware of how watermarks flow through these table functions > (an area that the paper does not go into). > > Julian > > > On Aug 19, 2019, at 6:59 PM, Rui Wang <ruw...@google.com.INVALID> wrote: > > > > Hi Calcite community, > > > > I have seen [1] is published, which proposes TVF style TUMBLE/HOP/SESSION > > windowing and EMIT syntax for materialization control. > > > > I tried to search dev@calcite and Calcite JIRA but didn't find those > > support above. So is Calcite already support TVF windowing and EMIT > syntax > > somehow, or it's a future work? > > > > > > > > [1]: https://arxiv.org/pdf/1905.12133.pdf > > > > > > -Rui > >
