Thanks for sharing this, Martijn--I will test it out!
- Jeremy
On 1/19/23, 12:59 PM, "Martijn Visser" mailto:martijnvis...@apache.org>> wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know
Hi Jeremy,
Have you looked into the CURRENT_WATERMARK function [1] which will allow
one to operate on late events without resorting to using the DataStream API?
Best regards,
Martijn
[1]
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/functions/systemfunctions/#temporal-func
Hi Dev Team,
I’m Jeremy, a Solutions Architect supporting the Kinesis Data Analytics for
Apache Flink service at AWS and wanted to open a discussion about a particular
problem our customers have faced, and how new functionality within the Table
and SQL API’s within Apache Flink could help solve