Thanks for the update, Hao. It is an interesting work, but I have a question. Flink is supposed to have a lot of advanced APIs which supports windowing, SQL-like functions like Siddhi. So what is the difference integrating Siddhi with Flink would make? Eagle uses Siddhi to calculate window based event stats for monitoring and data flow can be dynamically modified based on schema, but this integration between Siddhi and Flink only have static data model/schema?
Thanks Edward On Sun, Nov 26, 2017 at 7:00 PM, Hao Chen <[email protected]> wrote: > Hi, > > Inspired by eagle's streaming alert engine with siddhi, I created a generic > light-weight siddhi ondistributed streaming library (currently support > merged into flink community): https://github.com/apache/ > bahir-flink/pull/22, > especially for use case that would like to adopt siddhi in generic > streaming processing application but not only monitoring and alerting. > > - Hao >
