Timo Walther created FLINK-24103:
------------------------------------

             Summary: Create time-based LAST_VALUE / FIRST_VALUE
                 Key: FLINK-24103
                 URL: https://issues.apache.org/jira/browse/FLINK-24103
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Runtime
            Reporter: Timo Walther


LAST_VALUE and FIRST_VALUE don't support merging. As far I can see it, 
FLINK-20110 tries to solve this by using nano second timestamps internally. 
However, an easier and consistent approach could be to allow a time parameter 
in the signature:

{code}
LAST_VALUE(timestamp, value)
FIRST_VALUE(timestamp, value)
{code}

This allows merging based on a timestamp in HOP or SESSION windows.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to