Package dev.frostlake.functions

Interface MultiArgumentAccumulator

All Known Implementing Classes:
ApproxTopKAccumulator, ApproxTopKCombineAccumulator, ApproxTopKStateAccumulator, HashAggAccumulator, HllAccumulator
public interface MultiArgumentAccumulator
How an accumulator that needs more than one argument per row receives them. The engine's own multi-argument aggregates — MAX_BY, OBJECT_AGG, CORR, LISTAGG — are each fed by a branch that knows their accumulator class by name; a pack contributed through the FunctionProvider SPI has no such branch, so this interface is the seam it declares instead.

An accumulator implementing this is handed the whole row tuple in argument order, and the single-value AggregateFunction.Accumulator.accumulate(java.lang.Object) it still inherits is left for whatever it wants to do with the first one.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    accumulate(List<Object> argumentValues)
    One row's values, one per declared argument, in the order the call wrote them.

  • Method Details

    • accumulate

      void accumulate(List<Object> argumentValues)
      One row's values, one per declared argument, in the order the call wrote them.