[
https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447749#comment-17447749
]
Jark Wu commented on FLINK-24002:
---------------------------------
Thanks [~jingzhang] for hte summary. Your proposed syntax looks good to me.
Regarding to your questions:
1. I think it's find to not emit for windows not have enough size. But please
make sure the semantic is the same for both batch and streaming.
2. Agree.
3. It depends on the implementation of the count window. For example, the count
window of DataStream and Table SQL have different implementation and of course
have different state cleanup strategy.
> Support count window with the window TVF
> ----------------------------------------
>
> Key: FLINK-24002
> URL: https://issues.apache.org/jira/browse/FLINK-24002
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: Jing Zhang
> Priority: Minor
>
> For a long time, count window is supported in Table API, but not supported in
> SQL.
> With the new window TVF syntax, we can also introduce a new window function
> for count window.
> For example, the following TUMBLE_ROW assigns windows in 10 row-count
> interval.
> |{{SELECT}} {{*}}
> {{FROM}} {{{}TABLE{}}}{{{}({}}}
> {{ }}{{TUMBLE_ROW(}}
> {{ }}{{data => }}{{TABLE}} {{inputTable PARTITION BY order_id,}}
> {{ }}{{size}} {{=> 10));}}|
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
