Interface RecordAggregator<T>

    • Method Detail

      • withRecord

        T withRecord​(T state,
                     Record record)
        Adds statistics obtained from a single record to the aggregation state. Given that states are expected to be immutable, this returns a new aggregation state object. This function is required to be associative with the combining function: combine(a, withRecord(b, record)) == withRecord(combine(a, b), record)
        Parameters:
        state - the current aggregation state
        record - the record to ingest
        Returns:
        the aggregation state updated with this row