Developing streams processing applications with user-defined parallelism

To use data parallelism, add the @parallel annotation to either a primitive operator or a composite operator. When you submit a job for your application, parallel transformation occurs and either the operators or processing elements (PEs) are replicated. The parallel regions process streaming data concurrently and might increase performance.