Class AggregateAccumulator

java.lang.Object

com.kingsrook.qqq.backend.core.utils.aggregates.AggregateAccumulator

public class AggregateAccumulator
extends Object

Incremental aggregate state shared by memory and streamed execution.

Constructor Summary

Constructors

Constructor	Description
AggregateAccumulator(Aggregate aggregate, QFieldType sourceType)	Only percentiles and distinct counts retain input values.

Method Summary

Modifier and Type	Method	Description
void	accept(QRecord record)	Consume one row.
static int	compare(Serializable left, Serializable right)	Natural comparison with numeric normalization and nulls last.
Serializable	finish()	Finish one group.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AggregateAccumulator

public AggregateAccumulator(Aggregate aggregate,
 QFieldType sourceType)

Only percentiles and distinct counts retain input values.

Method Details

accept

public void accept(QRecord record)

Consume one row. Welford updates avoid retaining rows for variance and correlation.

finish

public Serializable finish()

Finish one group.

compare

public static int compare(Serializable left,
 Serializable right)

Natural comparison with numeric normalization and nulls last.