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