agregar

fábrica

agrupa linhas por uma ou mais colunas e calcula métricas de agregação (contagem, soma, média, máximo, mínimo).

---

quando usar

• construir métricas de negócio para a camada gold (ex: total vendido por região e mês)
• sumarizar um dataset detalhado (linha por transação) em um dataset de relatório (linha por dimensão)
• calcular contagens e totais antes de um dashboard de bi

---

configuração

campo	tipo	obrigatório	descrição
group_by	lista	não	colunas de agrupamento · vazio = agregação sobre a tabela inteira (uma única linha de resultado)
aggregations	lista de {field, fn, alias}	sim	uma entrada por métrica calculada

cada item de aggregations:

campo	descrição
field	coluna a agregar (* é aceito apenas com fn: count)
fn	count, sum, avg, max ou min
alias	nome da coluna de resultado

---

exemplo

{
  "group_by": ["regiao", "mes"],
  "aggregations": [
    { "field": "*", "fn": "count", "alias": "total_pedidos" },
    { "field": "valor", "fn": "sum", "alias": "valor_total" },
    { "field": "valor", "fn": "avg", "alias": "ticket_medio" }
  ]
}

produz uma linha por combinação de regiao + mes, com três métricas calculadas.

agregação sem agrupamento

{
  "aggregations": [
    { "field": "*", "fn": "count", "alias": "total_registros" },
    { "field": "valor", "fn": "sum", "alias": "valor_total_geral" }
  ]
}

sem group_by, o resultado é uma única linha com os totais gerais da tabela inteira.

combine com lakehouse writer para gold

o padrão mais comum é conectar este nó a um lakehouse writer apontando para a camada gold — a métrica calculada aqui vira uma tabela consultável diretamente por ferramentas de bi.