...
| Annotation | Description | Example |
|---|---|---|
@dist (parallel='<number of Storm tasks>) | The number of storm tasks in which the query should be run parallel. | @dist(parallel='4') |
@dist(execGroup='name of the group') | All the Siddhi queries in a particular execGroup will be executed in a single Siddhi bolt. | @dist(execGroup='Filtering') |
@Plan:dist(receiverParallelism='number of receiver spouts') | The number of event receiver spouts to be spawned for the Storm topology. | @Plan:dist(receiverParallelism='1') |
@Plan:dist(receiverParallelismpublisherParallelism='number of publisher bolts') | The number of event publisher bolts to be spawned for the Storm topology. | @Plan:dist(publisherParallelism='4') |
...