Hi Flink experts, I am getting ready to push a PR around a utility class for timeseries join
left.timestamp match to closest right.timestamp where right.timestamp <= left.timestamp. It makes very heavy use of Event.Time timers and has to do some manual DoFn cache work to get around some O(heavy) issues. Wanted to test things against Flink: In the capability matrix we have "~" for Timer support in Flink: https://beam.apache.org/documentation/runners/capability-matrix/ Is that page outdated, if not what are the areas that still need to be addressed please? Cheers Reza -- This email may be confidential and privileged. If you received this communication by mistake, please don't forward it to anyone else, please erase all copies and attachments, and please let me know that it has gone to the wrong person. The above terms reflect a potential business arrangement, are provided solely as a basis for further discussion, and are not intended to be and do not constitute a legally binding obligation. No legally binding obligations will be created, implied, or inferred until an agreement in final form is executed in writing by all parties involved.
