Re: [DISCUSS] Introduce Side Output Functionality to the Table & SQL API

2023-01-19 Thread Ber, Jeremy
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

Re: [DISCUSS] Introduce Side Output Functionality to the Table & SQL API

2023-01-19 Thread Martijn Visser
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

[DISCUSS] Introduce Side Output Functionality to the Table & SQL API

2023-01-19 Thread Ber, Jeremy
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