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

[Dan Berindei (JIRA)]

     [ https://issues.jboss.org/browse/ISPN-6691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dan Berindei updated ISPN-6691:
-------------------------------
           Status: Resolved  (was: Pull Request Sent)
    Fix Version/s: 9.0.0.Alpha3
       Resolution: Done


> 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.Alpha3, 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)