search

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)
Apache License 2.0
243 stars 96 forks source link

Added support for Joins among Siddhi streams #36

Closed Dr0na closed 5 years ago

Dr0na commented 5 years ago

When multiple streams are defined and a union operation is invoked on the streams for a Join query in siddhi throws an exception saying "Join is not supported now!". The following code snippet represents the use case. Its confusing as to whether the Join operation was no more supported or is yet to be supported. However, this code change would allow the Join operation.

DataStream output = cep.union("aStream","bStream").cql(controlEvents).returns("outputStream", Signal.class);

haoch commented 5 years ago

LGTM. Thanks for your contribution! @Dr0na