[
https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-24002:
-------------------------------
Description:
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.
{panel}
{panel}
|{{SELECT}} {{*}}
{{FROM}} {{{}TABLE{}}}{{{}({}}}
{{ }}{{TUMBLE_ROW(}}
{{ }}{{data => }}{{TABLE}} {{inputTable PARTITION BY order_id,}}
{{ }}{{size}} {{=> 10));}}|
was:
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.
{panel}
{panel}
|{{SELECT}} {{*}}
{{FROM}} {{TABLE}}{{(}}
{{ }}{{TUMBLE_ROW(}}
{{ }}{{data => }}{{TABLE}} {{inputTable,}}
{{ }}{{timecol => DESCRIPTOR(timecol),}}
{{ }}{{size}} {{=> 10));}}|
> 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
> Assignee: Yuepeng Pan
> 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.
> {panel}
> {panel}
> |{{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)
