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

Partition query support #49

Closed pranjal0811 closed 4 years ago

pranjal0811 commented 5 years ago

Fixes #45

I have added the support for the partition query.

Now the query like this - partition with ( deviceID of TempStream) begin from every e1=TempStream[roomNo == 5]<3> -> e2=TempStream [ roomNo == 6] within 30 seconds select 'partition' as str, e1.roomNo as room insert into DeviceTempStream; end; will work fine.

Reviews will be appreciated.

haoch commented 4 years ago

LGTM, @pranjal0811 Thanks for the contribution and I made a minor change on the version.