public class IntAgg extends Reducer
accCols, justColNames
Constructor and Description |
---|
IntAgg(java.lang.String outFieldName,
java.util.function.BiFunction<java.lang.Integer,Tuple,java.lang.Integer> fun) |
Modifier and Type | Method and Description |
---|---|
void |
add(Tuple t) |
java.lang.String[] |
getAccumulated() |
void |
reset() |
getColumnNames, getColumns
public IntAgg(java.lang.String outFieldName, java.util.function.BiFunction<java.lang.Integer,Tuple,java.lang.Integer> fun)
outFieldName
- - column descriptor of aggregate column
(use "n" or "'n'" for name n and indicate if values are quotedfun
- -- like (i,t) → i + t.getInt(column)
(i,t) → Math.min(i,t.getInt(column))