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