Timo Walther created FLINK-38352:
------------------------------------
Summary: Expose timestamp used in DefaultWatermarkGenerator
Key: FLINK-38352
URL: https://issues.apache.org/jira/browse/FLINK-38352
Project: Flink
Issue Type: Improvement
Components: Table SQL / Planner, Table SQL / Runtime
Reporter: Timo Walther
Assignee: Timo Walther
When implementing an advanced watermark strategy, it is not possible to extract
the timestamp from DefaultWatermarkGenerator because it is hidden in code
generation. We should at least provide an internal API to access the timestamp
for logging/metrics or other calculations.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
