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 Summary

    Modifier and Type
    Method
    Description
    <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.
    boolean
    isParallel()
    Return whether this pipeline should be executed in parallel.

  • Method Details

    • 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