sumSimpleState

Exemplo de uso do combinador sumSimpleState

​

Descrição

O combinador SimpleState pode ser aplicado à função sum para retornar a soma de todos os valores de entrada. Ele retorna o resultado com o tipo SimpleAggregateFunction.

​

Exemplo de uso

​

Acompanhando votos positivos e negativos

Vamos ver um exemplo prático usando uma tabela que rastreia votos em posts. Para cada post, queremos manter totais acumulados de votos positivos, votos negativos e uma pontuação geral. O uso do tipo SimpleAggregateFunction com sum é adequado para esse caso de uso, pois só precisamos armazenar os totais acumulados, e não o estado completo da agregação. Com isso, será mais rápido e não exigirá a mesclagem de estados agregados parciais.

Primeiro, criamos uma tabela para os dados brutos:

Query

CREATE TABLE raw_votes
(
    post_id UInt32,
    vote_type Enum8('upvote' = 1, 'downvote' = -1)
)
ENGINE = MergeTree()
ORDER BY post_id;

Em seguida, criamos uma tabela de destino que armazenará os dados agregados:

CREATE TABLE vote_aggregates
(
    post_id UInt32,
    upvotes SimpleAggregateFunction(sum, UInt64),
    downvotes SimpleAggregateFunction(sum, UInt64),
    score SimpleAggregateFunction(sum, Int64)
)
ENGINE = AggregatingMergeTree()
ORDER BY post_id;

Em seguida, criamos uma visão materializada com colunas do tipo SimpleAggregateFunction:

CREATE MATERIALIZED VIEW mv_vote_processor TO vote_aggregates
AS
SELECT
  post_id,
  -- Valor inicial para o estado de soma (1 se upvote, 0 caso contrário)
  toUInt64(vote_type = 'upvote') AS upvotes,
  -- Valor inicial para o estado de soma (1 se downvote, 0 caso contrário)
  toUInt64(vote_type = 'downvote') AS downvotes,
  -- Valor inicial para o estado de soma (1 para upvote, -1 para downvote)
  toInt64(vote_type) AS score
FROM raw_votes;

Insira dados de exemplo:

INSERT INTO raw_votes VALUES
    (1, 'upvote'),
    (1, 'upvote'),
    (1, 'downvote'),
    (2, 'upvote'),
    (2, 'downvote'),
    (3, 'downvote');

Faça uma consulta à visão materializada usando o combinador SimpleState:

SELECT
  post_id,
  sum(upvotes) AS total_upvotes,
  sum(downvotes) AS total_downvotes,
  sum(score) AS total_score
FROM vote_aggregates -- Consulte a tabela de destino
GROUP BY post_id
ORDER BY post_id ASC;

┌─post_id─┬─total_upvotes─┬─total_downvotes─┬─total_score─┐
│       1 │             2 │               1 │           1 │
│       2 │             1 │               1 │           0 │
│       3 │             0 │               1 │          -1 │
└─────────┴───────────────┴─────────────────┴─────────────┘

​

Veja também

• sum
• combinador SimpleState
• tipo SimpleAggregateFunction