Package com.tangosol.util.stream

Interface RemotePipeline<S_OUT>

  • All Superinterfaces:
    Serializable
    public interface RemotePipeline<S_OUT>
extends Serializable
    A serializable pipeline of intermediate stream operations.
    Since:
    12.2.1
    Author:
    as 2014.10.01

    • Method Detail

      • isParallel

        boolean isParallel()
        Return whether this pipeline should be executed in parallel.
        Returns:
        true if this pipeline should be executed in parallel, false otherwise

      • evaluate

        <K,​V> S_OUT evaluate​(Stream<? extends InvocableMap.Entry<? extends K,​? extends V>> stream)
        Evaluate this pipeline against the specified stream of InvocableMap.Entry objects.
        Type Parameters:
        K - key type
        V - value type
        Parameters:
        stream - the stream to evaluate pipeline against
        Returns:
        transformed stream