Package com.tangosol.util.stream

Contains classes to support functional-style operations on remote streams of elements, such as map-reduce transformations on collections.

Interface Summary

Interface	Description
BaseRemoteStream<T,S extends BaseStream<T,S>>	An extension of BaseStream that adds support for the RemotePipeline retrieval.
RemoteCollector<T,A,R>	An extension of Collector that adds serialization support.
RemoteDoubleStream	A sequence of primitive double-valued elements supporting sequential and parallel aggregate operations.
RemoteIntStream	A sequence of primitive int-valued elements supporting sequential and parallel aggregate operations.
RemoteLongStream	A sequence of primitive long-valued elements supporting sequential and parallel aggregate operations.
RemotePipeline<S_OUT>	A serializable pipeline of intermediate stream operations.
RemoteStream<T>	This interface is an extension of java.util.stream.Stream that captures lambdas used as method arguments as serializable lambdas.

Class Summary

Class	Description
RemoteCollectors	Static factory for various RemoteCollectors that can be executed in parallel in a distributed environment.