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;
got the exception!
throw new Exception("Unhandled execution element: " + executionElement.toString());
As the support was for supporting only the query execution. I have made some changes to support the partition execution element from the Sidhhi Manager itself. So the above query is running fine. But My question is, Would it be better to use partitioning from the query itself.
I am defining 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;got the exception!
throw new Exception("Unhandled execution element: " + executionElement.toString());As the support was for supporting only the query execution. I have made some changes to support the partition execution element from the Sidhhi Manager itself. So the above query is running fine. But My question is, Would it be better to use partitioning from the query itself.
I am raising PR for the code change