Interface Accumulating<T,​G,​A,​U>

  • Type Parameters:
    T - The item type
    G - The group key type - items are mapped to group keys
    A - The accumulator type
    U - The 'finalizer' - maps an accumulator to a final value
    All Known Implementing Classes:
    RecordReaderRdfTrigDataset.AccumulatingDataset

    public interface Accumulating<T,​G,​A,​U>
    • Method Detail

      • classify

        G classify​(T item)
      • createAccumulator

        A createAccumulator​(G groupKey)
      • accumulate

        void accumulate​(A accumulator,
                        T item)
      • accumulatedValue

        U accumulatedValue​(A accumulator)
      • 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: