Event trigger query

[Abhinav Sharma]

Newbie question: How can I set triggers to stream which execute according to system time? Eg: I want to sum the elements of streams at 1PM everyday.

[Colletta, Edward]

You can use a tumbling processing time window with an offset of 13 hours + your time zone offset. 

 

https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/operators/windows.html#tumbling-windows

https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.html

 

 

From: Abhinav Sharma <[hidden email]>
Sent: Tuesday, February 2, 2021 5:27 AM
To: [hidden email]
Subject: Event trigger query

 

This email is from an external source - exercise caution regarding links and attachments.

 

Newbie question: How can I set triggers to stream which execute according to system time? Eg: I want to sum the elements of streams at 1PM everyday.