[jira] [Created] (FLINK-32635) Add Lag function to Table API

[padavan (Jira)]

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)