[
https://issues.apache.org/jira/browse/FLINK-23023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JING ZHANG updated FLINK-23023:
-------------------------------
Description:
Support offset in window TVF. Offset could be positive duration and negative
duration.
Offset is a optional parameter for Tumble/Hop/Cumulative Window. If it is
specified, it is the last parameter of the window.
for Tumble window
{code:java}
TUMBLE(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '15' MINUTE, INTERVAL '5'
MINUTE){code}
for Hop Window
{code:java}
HOP(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '1' MINUTE, INTERVAL '15'
MINUTE,
INTERVAL '5' MINUTE){code}
for Cumulate Window
{code:java}
CUMULATE(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '1' MINUTE, INTERVAL '15'
MINUTE, INTERVAL '5' MINUTE){code}
was:
Support offset in window TVF. Offset could be positive duration and negative
duration.
for Tumble window
{code:java}
TUMBLE(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '15' MINUTE, INTERVAL '5'
MINUTE){code}
for Hop Window
{code:java}
HOP(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '1' MINUTE, INTERVAL '15'
MINUTE,
INTERVAL '5' MINUTE){code}
for Cumulate Window
{code:java}
CUMULATE(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '1' MINUTE, INTERVAL '15'
MINUTE, INTERVAL '5' MINUTE){code}
> Support offset in window TVF
> ----------------------------
>
> Key: FLINK-23023
> URL: https://issues.apache.org/jira/browse/FLINK-23023
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Affects Versions: 1.14.0
> Reporter: JING ZHANG
> Assignee: JING ZHANG
> Priority: Major
> Fix For: 1.14.0
>
>
> Support offset in window TVF. Offset could be positive duration and negative
> duration.
> Offset is a optional parameter for Tumble/Hop/Cumulative Window. If it is
> specified, it is the last parameter of the window.
> for Tumble window
> {code:java}
> TUMBLE(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '15' MINUTE, INTERVAL '5'
> MINUTE){code}
> for Hop Window
> {code:java}
> HOP(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '1' MINUTE, INTERVAL '15'
> MINUTE,
> INTERVAL '5' MINUTE){code}
> for Cumulate Window
> {code:java}
> CUMULATE(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '1' MINUTE, INTERVAL
> '15' MINUTE, INTERVAL '5' MINUTE){code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
