[jira] [Commented] (CALCITE-3271) TVF windowing and EMIT syntax support in Calcite
[ https://issues.apache.org/jira/browse/CALCITE-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913762#comment-16913762 ] Rui Wang commented on CALCITE-3271: --- Thanks Julian for you feedback. I will add more to this JIRA to clarify what it's supposed to do and replace terms by some more standard way (e.g. terms from SQL standard). Thanks Jark for the pointer of blink's practice. It's great to know that it would be also useful to other projects. Currently I should formalize what should be done under this JIRA. It would be nice to get help when on technique discussion, implementation, etc. > TVF windowing and EMIT syntax support in Calcite > > > Key: CALCITE-3271 > URL: https://issues.apache.org/jira/browse/CALCITE-3271 > Project: Calcite > Issue Type: Improvement > Components: core >Affects Versions: 1.20.0 >Reporter: Danny Chan >Assignee: Rui Wang >Priority: Major > > Copied from the mailing list: > 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 -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Commented] (CALCITE-3271) TVF windowing and EMIT syntax support in Calcite
[ https://issues.apache.org/jira/browse/CALCITE-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911978#comment-16911978 ] Jark Wu commented on CALCITE-3271: -- EMIT is very helpful to early fire windows and trigger on late records. We also have implemented a dialect in Blink SQL[1] and it is great to have EMIT syntax in Calcite. Looking forward to it. And glad to help if possible. [1]: http://blink.flink-china.org/dev/table/sql.html#emit-strategy > TVF windowing and EMIT syntax support in Calcite > > > Key: CALCITE-3271 > URL: https://issues.apache.org/jira/browse/CALCITE-3271 > Project: Calcite > Issue Type: Improvement > Components: core >Affects Versions: 1.20.0 >Reporter: Danny Chan >Assignee: Danny Chan >Priority: Major > > Copied from the mailing list: > 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 -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Commented] (CALCITE-3271) TVF windowing and EMIT syntax support in Calcite
[ https://issues.apache.org/jira/browse/CALCITE-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911973#comment-16911973 ] Julian Hyde commented on CALCITE-3271: -- "TVF" is jargon, and non-standard jargon at that. (I had to look it up, and I co-authored the paper.) Please expand/clarify. > TVF windowing and EMIT syntax support in Calcite > > > Key: CALCITE-3271 > URL: https://issues.apache.org/jira/browse/CALCITE-3271 > Project: Calcite > Issue Type: Improvement > Components: core >Affects Versions: 1.20.0 >Reporter: Danny Chan >Assignee: Danny Chan >Priority: Major > > Copied from the mailing list: > 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 -- This message was sent by Atlassian Jira (v8.3.2#803003)
