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

Dynamic partition #51

Closed pranjal0811 closed 4 years ago

pranjal0811 commented 5 years ago

In Siddhi, there is a partition query we need to dynamic partitioning on the partitioning element for working the partition well on increasing the parallelism just like the "group by" support is.

issues related - #49 #28

Now the query like - 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;

enables the dynamic runtime ad-hoc cep runtime. like in #28

haoch commented 5 years ago

@pranjal0811 Thanks for your contribution!

haoch commented 4 years ago

@pranjal0811 Thanks for your contribution!