[
https://issues.apache.org/jira/browse/CALCITE-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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)
