Package com.tangosol.util.stream

package com.tangosol.util.stream
Contains classes to support functional-style operations on remote streams of elements, such as map-reduce transformations on collections.
  • Class
    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.
    RemoteCollectors
    Static factory for various RemoteCollectors that can be executed in parallel in a distributed environment.
    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.