Hi all! I've created a FLIP for the trigger DSL. This is the triggers that we want Apache Flink to support out-of-the-box. This proposal builds on various discussions on the mailing list and aims at serving as a base for further ones.
https://cwiki.apache.org/confluence/display/FLINK/FLIP-9%3A+Trigger+DSL <https://cwiki.apache.org/confluence/display/FLINK/FLIP-9:+Trigger+DSL> FLIP-9 provides a description of the triggers Flink already offers, the new that we think should be added, how the APIs could look like, some discussion on the implementation implications and some ideas on how to implement them. There is also a shared document giving a bit more insight on the implementation implications. Feel free to read but please keep the discussion in the mailing list. https://docs.google.com/a/data-artisans.com/document/d/1vESGQ913oR-DnE1jmFiihvLBU6_UDo-1DRgoHtSgu30/edit?usp=sharing <https://docs.google.com/a/data-artisans.com/document/d/1vESGQ913oR-DnE1jmFiihvLBU6_UDo-1DRgoHtSgu30/edit?usp=sharing> I would like to start working on an the implementation next week. Let the discussion begin! Kostas
