public interface RemotePipeline<S_OUT> extends Serializable
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.
|
boolean isParallel()
true
if this pipeline should be executed in parallel,
false
otherwise<K,V> S_OUT evaluate(Stream<? extends InvocableMap.Entry<? extends K,? extends V>> stream)
K
- key typeV
- value typestream
- the stream to evaluate pipeline against