Package net.sansa_stack.hadoop.core
Interface Accumulating<T,G,A,U>
-
- Type Parameters:
T
- The item typeG
- The group key type - items are mapped to group keysA
- The accumulator typeU
- The 'finalizer' - maps an accumulator to a final value
- All Known Implementing Classes:
RecordReaderRdfTrigDataset.AccumulatingDataset
public interface Accumulating<T,G,A,U>
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description void
accumulate(A accumulator, T item)
U
accumulatedValue(A accumulator)
G
classify(T item)
A
createAccumulator(G groupKey)
static <T> Accumulating
identity()
Identity accumulator - turns each item into a group that contains only the item and whose value is the item
-
-
-
Method Detail
-
identity
static <T> Accumulating identity()
Identity accumulator - turns each item into a group that contains only the item and whose value is the item- Type Parameters:
T
-- Returns:
-
-