A generic parallel pattern interface for stream and data processing | doi.page