public abstract class BKeyedGatherUnGroupedCompute<K,T> extends KeyedGatherCompute<K,T>
Constructor and Description |
---|
BKeyedGatherUnGroupedCompute() |
Modifier and Type | Method and Description |
---|---|
boolean |
execute(IMessage<java.util.Iterator<Tuple<K,T>>> content)
Execute with an incoming message
|
abstract boolean |
keyedGather(java.util.Iterator<Tuple<K,T>> content) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
endExecute
public abstract boolean keyedGather(java.util.Iterator<Tuple<K,T>> content)
keyedGather
in class KeyedGatherCompute<K,T>