Hi, During my recent testing, Siddhi does not allow partition with two attributes of the same stream. For example, the following query throws *SiddhiAppValidationException* with a message partition already exists because the streamId is used to uniquely identify the partition [1].
define stream PacketStream (srcIp string, dstIp string, packets int); partition with (srcIp of PacketStream, dstIp of PacketStream) begin from PacketStream select srcIp, dstIp, count(packets) as count insert into OutputStream; end; I wonder whether it is not supported due to any constraints. If there is nothing like that, I can have a look at it. FYI: I tried to change the partition id as a combination of stream id and the attribute name but it does not register a PartitionReceiver for the later one. [1] https://github.com/slgobinath/siddhi/blob/master/modules/siddhi-query-api/src/main/java/org/wso2/siddhi/query/api/execution/partition/Partition.java#L101 Thanks & Regards, Gobinath -- *Gobinath** Loganathan* Graduate Student, Electrical and Computer Engineering, Western University. Email : [email protected] Blog : javahelps.com <http://www.javahelps.com/>
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
