Partilhar via

Função aggregate

  • Artigo

Aplica-se a: Marque Sim Databricks SQL Marque Sim Databricks Runtime

Agrega elementos em uma matriz usando um agregador personalizado. Esta função é sinónimo de função redutora.

Sintaxe

aggregate(expr, start, merge [, finish])

Argumentos

  • expr: Uma expressão ARRAY.
  • start: Um valor inicial de qualquer tipo.
  • merge: Uma função lambda usada para agregar o elemento atual.
  • finish: Uma função lambda opcional usada para finalizar a agregação.

Devoluções

O tipo de resultado corresponde ao tipo de resultado da função lambda, finish se existir ou start.

Aplica uma expressão a um estado inicial e a todos os elementos da matriz e reduz isso a um único estado. O estado final é convertido no resultado final através da aplicação de uma finish função.

A merge função usa dois parâmetros. O primeiro é o acumulador, o segundo o elemento a ser agregado. O acumulador e o resultado devem ser do tipo startde . A função opcional finish usa um parâmetro e retorna o resultado final.

Exemplos

> SELECT aggregate(array(1, 2, 3), 0, (acc, x) -> acc + x);
 6
> SELECT aggregate(array(1, 2, 3), 0, (acc, x) -> acc + x, acc -> acc * 10);
 60

> SELECT aggregate(array(1, 2, 3, 4),
                   named_struct('sum', 0, 'cnt', 0),
                   (acc, x) -> named_struct('sum', acc.sum + x, 'cnt', acc.cnt + 1),
                   acc -> acc.sum / acc.cnt) AS avg
 2.5