Package dev.frostlake.functions.aggregate

Class ApproxTopKCombine

java.lang.Object

dev.frostlake.functions.BuiltInFunction

dev.frostlake.functions.AggregateFunction

dev.frostlake.functions.aggregate.ApproxTopKCombine

public class ApproxTopKCombine
extends AggregateFunction

APPROX_TOP_K_COMBINE(state [, counters]): the APPROX_TOP_K_ACCUMULATE states of its input merged into one — equal values add their counts, nothing is inherited — and trimmed to counters (a constant between 1 and 100000; by default the inputs' own limit, which every input must share: differing limits refuse with Invalid parameter value: ApproxTopK state. Reason: combining states with different numbers of counters). The result's datatype and width are the first state's; NULL inputs are skipped, and a combine that saw no state is the empty MISSING state with one counter. An argument that is not a state refuses with … Reason: invalid type.

Nested Class Summary

Nested classes/interfaces inherited from class dev.frostlake.functions.AggregateFunction

AggregateFunction.Accumulator

Constructor Summary

Constructors

Constructor	Description
ApproxTopKCombine()

Method Summary

Modifier and Type	Method	Description
AggregateFunction.Accumulator	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.
Object	evaluate(List<Object> args)	Computes the function's result over its already-evaluated argument values.
int	getMaxArgCount()	The most arguments a call to this function may pass; Integer.MAX_VALUE marks a variadic function (see BuiltInFunction.isVariadic()).
int	getMinArgCount()	The fewest arguments a call to this function may pass; fewer is an argument-count error.

Methods inherited from class dev.frostlake.functions.BuiltInFunction

approximateRejection, binaryRejection, booleanRejection, evaluate, fileRejection, geoRejection, getName, getReturnType, isVariadic, refusesMissingArgumentsByType, semiStructuredRejection, structuredRejection, temporalRejection, temporalRejection, temporalRejection, textRejection, uuidRejection, vectorRejection

Methods inherited from class java.lang.Object

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

Constructor Details

ApproxTopKCombine

public ApproxTopKCombine()

Method Details

createAccumulator

public AggregateFunction.Accumulator createAccumulator()

Description copied from class: AggregateFunction

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.

Specified by:

createAccumulator in class AggregateFunction

Returns:

a new accumulator starting from this aggregate's empty-group state

evaluate

public Object evaluate(List<Object> args)

Description copied from class: BuiltInFunction

Computes the function's result over its already-evaluated argument values. A SQL NULL argument arrives as Java null, and returning null makes the SQL result NULL.

Specified by:

evaluate in class BuiltInFunction

Parameters:

args - the argument values, in call order

Returns:

the function's value for these arguments, or null for SQL NULL

getMinArgCount

public int getMinArgCount()

Description copied from class: BuiltInFunction

The fewest arguments a call to this function may pass; fewer is an argument-count error.

Specified by:

getMinArgCount in class BuiltInFunction

Returns:

the minimum accepted argument count

getMaxArgCount

public int getMaxArgCount()

Description copied from class: BuiltInFunction

The most arguments a call to this function may pass; Integer.MAX_VALUE marks a variadic function (see BuiltInFunction.isVariadic()).

Specified by:

getMaxArgCount in class BuiltInFunction

Returns:

the maximum accepted argument count