Uses of Interface
dev.frostlake.functions.AggregateFunction.Accumulator

Packages that use AggregateFunction.Accumulator

Package	Description
dev.frostlake.functions
dev.frostlake.functions.aggregate

Uses of AggregateFunction.Accumulator in dev.frostlake.functions

Methods in dev.frostlake.functions that return AggregateFunction.Accumulator

Modifier and Type	Method	Description
abstract AggregateFunction.Accumulator	AggregateFunction.createAccumulator()	Creates the fresh, empty per-group state for one evaluation of this aggregate; the executor makes one per group (or per window partition) and never shares them.

Methods in dev.frostlake.functions with parameters of type AggregateFunction.Accumulator

Modifier and Type	Method	Description
void	AggregateFunction.Accumulator.merge(AggregateFunction.Accumulator other)	Folds another accumulator's state into this one, combining two partial aggregations of the same group.

Uses of AggregateFunction.Accumulator in dev.frostlake.functions.aggregate

Classes in dev.frostlake.functions.aggregate that implement AggregateFunction.Accumulator

Modifier and Type	Class	Description
class	AnyValueAccumulator	Accumulator for AnyValue.
class	ApproxPercentileAccumulator	Accumulator for APPROX_PERCENTILE(expr, percentile).
class	ApproxTopKAccumulator	The accumulator of ApproxTopK: a TopKSummary sized by the call's third argument, answering the first k of its ranking.
class	ApproxTopKCombineAccumulator	The accumulator of ApproxTopKCombine: every input state is read into one unbounded TopKSummary, which is trimmed to the result's counter limit only once all of them are in.
class	ApproxTopKStateAccumulator	The accumulator of ApproxTopKAccumulate: a TopKSummary sized by the call's second argument, serialised whole.
class	ArrayAggAccumulator	Accumulator for ARRAY_AGG(expr).
class	ArrayUnionAggAccumulator	Accumulator for ArrayUnionAgg — Snowflake's MULTISET union (live-verified): every element appears with the MAXIMUM multiplicity it has in any single input array, so [2,2,2] UNION [2,2] is [2,2,2] and [5,5] alone keeps both.
class	ArrayUniqueAggAccumulator	Accumulator for ArrayUniqueAgg.
class	AvgAccumulator	Accumulator for Avg, delegating the numeric result to AggregateNumerics.avg(Iterable) so every AVG code path shares the same live-verified Snowflake typing: fixed-point inputs (Long/Integer/ BigDecimal) yield a BigDecimal with scale = (max input scale) + 6 rounded HALF_UP and trailing zeros kept (AVG of 90 and 95 is exactly 92.500000), while any Double/Float/VARIANT input keeps the double average.
class	BitAndAccumulator	Accumulator for BitAndAgg.
class	BitOrAccumulator	Accumulator for BitOrAgg.
class	BitXorAccumulator	Accumulator for BitXorAgg.
class	BoolAndAccumulator	Accumulator for BoolAndAgg.
class	BoolOrAccumulator	Accumulator for BoolOrAgg.
class	BoolXorAccumulator	Accumulator for BoolXorAgg.
class	CorrAccumulator	Accumulator for Corr.
class	CountAccumulator	Accumulator for Count.
class	CountIfAccumulator	Accumulator for CountIf.
class	CovarAccumulator
class	HashAggAccumulator	Accumulator for HashAgg.
class	HllAccumulator	HyperLogLog sketch for APPROX_COUNT_DISTINCT (Flajolet et al.), with linear counting in the small-cardinality range.
class	KurtosisAccumulator	Accumulator for Kurtosis.
class	ListAggAccumulator	Accumulator for LISTAGG: concatenates the non-null accumulated values with ListAggAccumulator.delimiter.
class	MaxAccumulator	Accumulator for Max.
class	MaxByMinByAccumulator	Shared accumulator for MaxBy and MinBy.
class	MedianAccumulator	Accumulator for Median, delegating to AggregateNumerics.median(Iterable) so the interpolating percentiles share one typing rule.
class	MinAccumulator	Accumulator for Min.
class	ModeAccumulator	MODE's accumulator: the most frequent non-NULL value, a tie going to the value seen FIRST.
class	ObjectAggAccumulator	Accumulator for OBJECT_AGG(key, value) — collects key/value pairs into one OBJECT.
class	PercentileContAccumulator	Accumulator for PercentileCont, delegating to AggregateNumerics.percentileCont(Iterable, double) — the same rule MEDIAN uses, MEDIAN being this function at one half.
class	PercentileDigestAccumulator	The accumulator of ApproxPercentileAccumulate: one centroid of weight 1 per non-NULL value.
class	PercentileDigestCombineAccumulator	The accumulator of ApproxPercentileCombine: every input state's centroids, gathered.
class	PercentileDiscAccumulator	Accumulator for PercentileDisc, delegating to AggregateNumerics.percentileDisc(Iterable, double).
class	RegrAccumulator	Shared accumulator for the REGR_* linear-regression family.
class	SkewAccumulator	Accumulator for Skew.
class	StdDevAccumulator	Accumulator for StdDev.
class	StdDevPopAccumulator	Accumulator for StdDevPop.
class	SumAccumulator	Accumulator for Sum.
class	VarianceAccumulator	Accumulator for Variance.
class	VarPopAccumulator	Accumulator for VarPop.
class	VectorAggregateAccumulator	The element-wise vector aggregates' accumulator, shared by VectorSum, VectorAvg, VectorMin and VectorMax.

Methods in dev.frostlake.functions.aggregate that return AggregateFunction.Accumulator

Modifier and Type	Method	Description
AggregateFunction.Accumulator	AnyValue.createAccumulator()
AggregateFunction.Accumulator	ApproxCountDistinct.createAccumulator()
AggregateFunction.Accumulator	ApproxPercentile.createAccumulator()
AggregateFunction.Accumulator	ApproxPercentileAccumulate.createAccumulator()
AggregateFunction.Accumulator	ApproxPercentileCombine.createAccumulator()
AggregateFunction.Accumulator	ApproxTopK.createAccumulator()
AggregateFunction.Accumulator	ApproxTopKAccumulate.createAccumulator()
AggregateFunction.Accumulator	ApproxTopKCombine.createAccumulator()
AggregateFunction.Accumulator	ArrayAgg.createAccumulator()
AggregateFunction.Accumulator	ArrayUnionAgg.createAccumulator()
AggregateFunction.Accumulator	ArrayUniqueAgg.createAccumulator()
AggregateFunction.Accumulator	Avg.createAccumulator()
AggregateFunction.Accumulator	BitAndAgg.createAccumulator()
AggregateFunction.Accumulator	BitOrAgg.createAccumulator()
AggregateFunction.Accumulator	BitXorAgg.createAccumulator()
AggregateFunction.Accumulator	BoolAndAgg.createAccumulator()
AggregateFunction.Accumulator	BoolOrAgg.createAccumulator()
AggregateFunction.Accumulator	BoolXorAgg.createAccumulator()
AggregateFunction.Accumulator	Corr.createAccumulator()
AggregateFunction.Accumulator	Count.createAccumulator()
AggregateFunction.Accumulator	CountIf.createAccumulator()
AggregateFunction.Accumulator	CovarPop.createAccumulator()
AggregateFunction.Accumulator	CovarSamp.createAccumulator()
AggregateFunction.Accumulator	HashAgg.createAccumulator()
AggregateFunction.Accumulator	Kurtosis.createAccumulator()
AggregateFunction.Accumulator	ListAgg.createAccumulator()
AggregateFunction.Accumulator	Max.createAccumulator()
AggregateFunction.Accumulator	MaxBy.createAccumulator()
AggregateFunction.Accumulator	Median.createAccumulator()
AggregateFunction.Accumulator	Min.createAccumulator()
AggregateFunction.Accumulator	MinBy.createAccumulator()
AggregateFunction.Accumulator	Mode.createAccumulator()
AggregateFunction.Accumulator	ObjectAgg.createAccumulator()
AggregateFunction.Accumulator	PercentileCont.createAccumulator()
AggregateFunction.Accumulator	PercentileDisc.createAccumulator()
AggregateFunction.Accumulator	RegrAvgx.createAccumulator()
AggregateFunction.Accumulator	RegrAvgy.createAccumulator()
AggregateFunction.Accumulator	RegrCount.createAccumulator()
AggregateFunction.Accumulator	RegrIntercept.createAccumulator()
AggregateFunction.Accumulator	RegrR2.createAccumulator()
AggregateFunction.Accumulator	RegrSlope.createAccumulator()
AggregateFunction.Accumulator	RegrSxx.createAccumulator()
AggregateFunction.Accumulator	RegrSxy.createAccumulator()
AggregateFunction.Accumulator	RegrSyy.createAccumulator()
AggregateFunction.Accumulator	Skew.createAccumulator()
AggregateFunction.Accumulator	StdDev.createAccumulator()
AggregateFunction.Accumulator	StdDevPop.createAccumulator()
AggregateFunction.Accumulator	StdDevSamp.createAccumulator()
AggregateFunction.Accumulator	Sum.createAccumulator()
AggregateFunction.Accumulator	Variance.createAccumulator()
AggregateFunction.Accumulator	VarPop.createAccumulator()
AggregateFunction.Accumulator	VarSamp.createAccumulator()
AggregateFunction.Accumulator	VectorAvg.createAccumulator()
AggregateFunction.Accumulator	VectorMax.createAccumulator()
AggregateFunction.Accumulator	VectorMin.createAccumulator()
AggregateFunction.Accumulator	VectorSum.createAccumulator()

Methods in dev.frostlake.functions.aggregate with parameters of type AggregateFunction.Accumulator

Modifier and Type	Method	Description
void	AnyValueAccumulator.merge(AggregateFunction.Accumulator other)
void	ApproxPercentileAccumulator.merge(AggregateFunction.Accumulator other)
void	ApproxTopKAccumulator.merge(AggregateFunction.Accumulator other)
void	ApproxTopKCombineAccumulator.merge(AggregateFunction.Accumulator other)
void	ApproxTopKStateAccumulator.merge(AggregateFunction.Accumulator other)
void	ArrayAggAccumulator.merge(AggregateFunction.Accumulator other)
void	ArrayUnionAggAccumulator.merge(AggregateFunction.Accumulator other)
void	ArrayUniqueAggAccumulator.merge(AggregateFunction.Accumulator other)
void	AvgAccumulator.merge(AggregateFunction.Accumulator other)
void	BitAndAccumulator.merge(AggregateFunction.Accumulator other)
void	BitOrAccumulator.merge(AggregateFunction.Accumulator other)
void	BitXorAccumulator.merge(AggregateFunction.Accumulator other)
void	BoolAndAccumulator.merge(AggregateFunction.Accumulator other)
void	BoolOrAccumulator.merge(AggregateFunction.Accumulator other)
void	BoolXorAccumulator.merge(AggregateFunction.Accumulator other)
void	CorrAccumulator.merge(AggregateFunction.Accumulator other)
void	CountAccumulator.merge(AggregateFunction.Accumulator other)
void	CountIfAccumulator.merge(AggregateFunction.Accumulator other)
void	CovarAccumulator.merge(AggregateFunction.Accumulator other)
void	HashAggAccumulator.merge(AggregateFunction.Accumulator other)
void	HllAccumulator.merge(AggregateFunction.Accumulator other)
void	KurtosisAccumulator.merge(AggregateFunction.Accumulator other)
void	ListAggAccumulator.merge(AggregateFunction.Accumulator other)
void	MaxAccumulator.merge(AggregateFunction.Accumulator other)
void	MaxByMinByAccumulator.merge(AggregateFunction.Accumulator other)
void	MedianAccumulator.merge(AggregateFunction.Accumulator other)
void	MinAccumulator.merge(AggregateFunction.Accumulator other)
void	ModeAccumulator.merge(AggregateFunction.Accumulator other)
void	ObjectAggAccumulator.merge(AggregateFunction.Accumulator other)
void	PercentileContAccumulator.merge(AggregateFunction.Accumulator other)
void	PercentileDigestAccumulator.merge(AggregateFunction.Accumulator other)
void	PercentileDigestCombineAccumulator.merge(AggregateFunction.Accumulator other)
void	PercentileDiscAccumulator.merge(AggregateFunction.Accumulator other)
void	RegrAccumulator.merge(AggregateFunction.Accumulator other)
void	SkewAccumulator.merge(AggregateFunction.Accumulator other)
void	StdDevAccumulator.merge(AggregateFunction.Accumulator other)
void	StdDevPopAccumulator.merge(AggregateFunction.Accumulator other)
void	SumAccumulator.merge(AggregateFunction.Accumulator other)
void	VarianceAccumulator.merge(AggregateFunction.Accumulator other)
void	VarPopAccumulator.merge(AggregateFunction.Accumulator other)
void	VectorAggregateAccumulator.merge(AggregateFunction.Accumulator other)