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