Hi all, If you're familiar with concepts of event time windowing, watermarks, triggers, and accumulation used in Google Cloud Dataflow and Apache Beam, I invite you to review this PR https://github.com/apache/apex-malhar/pull/319.
It is a preliminary design and a rough implementation of an Apex operator that supports those concepts. Any feedback is appreciated. Thank you. David
