padavan created FLINK-32635:
-------------------------------
Summary: Add Lag function to Table API
Key: FLINK-32635
URL: https://issues.apache.org/jira/browse/FLINK-32635
Project: Flink
Issue Type: Improvement
Components: Table SQL / API
Reporter: padavan
I was surprised that the Table API doesn't have a LAG function.
Expected result:
{code:java}
Table win = t
.window(Tumble.over(lit(10).seconds()).on($("proctime")).as("w"))
.groupBy($("w"), $("userId"))
.select( $("userId"), $("myfield").lag(1) );{code}
or
{code:java}
$("myfield").over($("w")).lag(1){code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
