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)