...
| Annotation | Description |
|---|---|
@dist(execGroup='name of the group') | All the executional elements with the same execution group are executed in the same Siddhi application. When different execution groups are mentioned within the same distributed Siddhi application, WSO2 SP initiates a separate Siddhi Application per execution group. In each separated Siddhi application, only the executional elements assigned to the relevant execution group are executed. Executional elements that have no execution group assigned to them are executed in a separate SP instance. |
@dist (parallel='number of parallel instances’) | The number of instances in which the executional element must be executed in parallel. All the executional elements assigned to a specific execution group (i.e., via the When the number of parallel instances to be run is not given for the executional elements assigned to an execution group , only one Siddhi application is initiated for that execution group. This can also be applied to sources. When sources are provided with parallelism count passthough Siddhi apps equal to the parallel count will be If a parallelism count is specified within a source annotation, a number of passthrough Siddhi applications equal to that count are generated and deployed. |
Example
The following is a sample distributed Siddhi application.
...