Beam SQL aggregate functions (Calcite)

This page documents built-in functions supported by Beam SQL when using Apache Calcite.

See also Calcite SQL’s operators and functions reference.

Operator syntax Description
COUNT(*) Returns the number of input rows
AVG(numeric) Returns the average (arithmetic mean) of numeric across all input values
SUM(numeric) Returns the sum of numeric across all input values
MAX(value) Returns the maximum value of value across all input values
MIN(value) Returns the minimum value of value across all input values