public class DoubleAgg extends Reducer
accCols, justColNames
Constructor and Description |
---|
DoubleAgg(java.lang.String fieldName,
java.util.function.BiFunction<java.lang.Double,Tuple,java.lang.Double> fun) |
Modifier and Type | Method and Description |
---|---|
void |
add(Tuple t) |
java.lang.String[] |
getAccumulated() |
void |
reset() |
getColumnNames, getColumns
public DoubleAgg(java.lang.String fieldName, java.util.function.BiFunction<java.lang.Double,Tuple,java.lang.Double> fun)
fieldName
- -- name of field.fun
- -- like (d,t) → d + t.getDouble(column)
(d,t) → Math.min(d,t.getDouble(column))