Jason Choi

Results 3 comments of Jason Choi

hi, haoch I don't want to reload flink driver when add a new pattern or change one. Here is my way: extend AbstractSiddhiOperator with implementing TwoInputStreamOperator, while one input accepts...

ok, i have found the way. ``` DataStream output = SiddhiCEP .define(...) .cql(DataStream controlStream) .return(...); ```