Dale LaBossiere created QUARKS-173:
--------------------------------------
Summary: Add load balanced parallel()
Key: QUARKS-173
URL: https://issues.apache.org/jira/browse/QUARKS-173
Project: Quarks
Issue Type: Improvement
Reporter: Dale LaBossiere
Assignee: Dale LaBossiere
Add an implementation that allocates a received tuple to the first "free"
channel. A "load balanced splitter" is used internally.
e.g.,
```
public static <T,R> TStream<R> parallelBalanced(TStream<T> stream, int width,
BiFunction<TStream<T>,Integer,TStream<R>> pipeline) {
```
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
