[infinispan-issues] [JBoss JIRA] (ISPN-6691) Simplify Distributed Stream local intermediate operations

[William Burns (JIRA)]

William Burns created ISPN-6691:
-----------------------------------

             Summary: Simplify Distributed Stream local intermediate operations
                 Key: ISPN-6691
                 URL: https://issues.jboss.org/browse/ISPN-6691
             Project: Infinispan
          Issue Type: Enhancement
          Components: Distributed Execution and Map/Reduce
            Reporter: William Burns
            Assignee: William Burns
             Fix For: 9.0.0.Final


Currently whenever a local intermediate operation (sort, limit, distinct, skip) is invoked on a distributed stream it tries to separate the invoctions based on if it should run remotely or locally.  This code is quite hard to read and maintain.  It also prevents the ability from adding new functionality without complicating the code substantially.

We can rewrite this to have a new IntermediateDistributedCache that acts a bridge between the distributed (remote) stream and the local stream required for these operations.



--
This message was sent by Atlassian JIRA
(v6.4.11#64026)