WSO2 DAS uses storm based distributed execution plan to store the processing logic to be used in a distributed mode deployment.
Writing an execution plan
The procedure for creating an execution plan is the same as that in Creating a Standalone Execution Plan. In addition, the following annotations are used in the Siddhi queries.
|The number of storm tasks in which the query should be run parallel.|
All the Siddhi queries in a particular execGroup will be executed in a single Siddhi bolt.
|The number of event receiver spouts to be spawned for the Storm topology.|
|The number of event publisher spouts to be spawned for the Storm topology.|
The following execution plan is populated with the above mentioned annotations.
Every Siddhi query in a particular
execGroupshould have the same number of tasks as shown in the execution plan above ( e.g.,
parallel = '4'). If the queries need to be distributed across different siddhi bolts, the
execGroupnames of the queries should differ from each other.