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 and 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 Detail

isParallel

boolean isParallel()

Return whether this pipeline should be executed in parallel.

Returns:

<c>true</c> if this pipeline should be executed in parallel, <c>false</c> 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