[infinispan-dev] Distributed Streams

[William Burns]

Hello everyone,

I wanted to let you know I wrote up a design documenting the successor to
EntryRetriever, Distributed Streams [1] !

Any comments or feedback would be much appreciated.

I especially would like targeted feedback regarding:

1. The operators forEach and peek may want to be ran locally.  Should we
have an overridden method so users can pick which they want?  Personally I
feel that peek is too specific to matter and forEach can always be done by
the caller locally if desired.
2. The intermediate operators limit and skip do not seem worth implementing
unless we have sorting support. (Sorting support will come later).  I am
thinking to not support these until sorting is added.

Thanks,

 - Will

[1] https://github.com/infinispan/infinispan/wiki/Distributed-Stream-Support
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/infinispan-dev/attachments/20150527/0c6b1533/attachment.html