public static class ReduceFunctions.ReduceFuncImpl extends java.lang.Object implements ReduceFunc, java.io.Serializable
Constructor and Description |
---|
ReduceFuncImpl(byte[] pyBinary) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
reduce(java.lang.Object t1,
java.lang.Object t2)
Reduce the t1 and t2 into a single value
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onMessage
public java.lang.Object reduce(java.lang.Object t1, java.lang.Object t2)
ReduceFunc
reduce
in interface ReduceFunc
t1
- input onet2
- input two