Aggregate
Aggregate functions perform a calculation on multiple values to return a single result. The following functions can be included in your jobs:
Approximates the number of distinct non-null input values.
Approximates the number of distinct values for each given group.
Computes the average (arithmetic mean) of all input values.
Computes the average (arithmetic mean) of all input values for each given group.
Gets the average value per time interval.
Collects a set of all values for a given field.
Collects a set of all values for a field for each given group.
Counts the number of non-null input values.
Counts the number of input rows.
Counts the number of distinct non-null input values.
Counts the number of items for each given group.
Counts the number of TRUE input values.
Collects an array of session start and end times.
Gets the first input value to arrive for each group.
Gets the first array of values seen in the events within the time window.
Gets an array of the first values per given group in the time window.
Gets the first value per time interval.
Gets the last input value to arrive for each group.
Gets the last array of values seen in the events within the time window.
Gets an array of the last values per group in the time window.
Gets the last k values per group.
Gets the last K values per given group.
Gets the last value per time interval.
Computes the maximum of all input values.
Gets the value that corresponds to the maximum value of a different field in the time window.
Collects the maximum value per given group.
Gets the maximum value per time interval.
Computes the minimum of all input values.
Gets the value that corresponds to the minimum value of a different field in the time window.
Collects the minimum value per given group.
Gets the minimum value per time interval.
Counts the number of sessions.
Computes the standard deviation of a set of numbers.
Computes the standard deviation of a set of numbers per given group.
Computes the maximum of all input string values.
Collects the maximum string value per given group.
Collects the minimum string value per given group.
Computes the sum of all input values.
Computes the sum of all input values for each given group.
Gets the sum of all values per time interval.
The weighted average of a field in the time window.
Last updated