Hi all, I have started working on the $subject.
In current Siddhi implementation, for a partition query execution will be carried out for each partition key separately and results will be directed to a single stream. Ones the results of the partition query is sent to the output stream there is no way to identify from which partition key the event was generated and carry out operations to events generated by each partition key separately. To overcome that we are introducing inner streams. Inner streams reside inside a partition and they are only visible to the queries in that partition. Inner stream allows carrying out same operation to results of each partition key separately. If an inner stream is used as the output stream of a query inside a partition, then events generated by each partition key will be directed to a different stream with same stream definition. As shown in the diagram for query1, stream A will get partitioned based on a partition key and operations are carried out separately for each partition key. Using an inner stream we can further carryout operations to results of each partition key individually. Queries outside the partition will not have any knowledge about stream B as it is an inner stream. ​Thanks -- *Thanks & Regards,Sachini JayasekaraSoftware Engineer; **WSO2 Inc. * *lean . enterprise . middleware | http://wso2.com <http://wso2.com> *
_______________________________________________ Architecture mailing list [email protected] https://mail.wso2.org/cgi-bin/mailman/listinfo/architecture
