sumSimpleState

描述

SimpleState 组合器可以应用于 sum 函数，以返回所有输入值的总和。它将结果返回为 SimpleAggregateFunction 类型。

示例用法

跟踪点赞和点踩

让我们看一个使用跟踪帖子投票的表的实际示例。对于每个帖子，我们希望维护点赞、点踩和整体得分的运行总计。使用 SimpleAggregateFunction 类型与 sum 结合适合这类用例，因为我们只需要存储运行总计，而不需要整个聚合状态。因此，它将更快，并且不需要合并部分聚合状态。

首先，我们创建一个用于原始数据的表：

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

接下来，我们创建一个目标表，用于存储聚合数据：

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;

然后，我们创建一个具有 SimpleAggregateFunction 类型列的物化视图：

CREATE MATERIALIZED VIEW mv_vote_processor TO vote_aggregates
AS
SELECT
  post_id,
  -- Initial value for sum state (1 if upvote, 0 otherwise)
  toUInt64(vote_type = 'upvote') AS upvotes,
  -- Initial value for sum state (1 if downvote, 0 otherwise)
  toUInt64(vote_type = 'downvote') AS downvotes,
  -- Initial value for sum state (1 for upvote, -1 for downvote)
  toInt64(vote_type) AS score
FROM raw_votes;

插入示例数据：

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

使用 SimpleState 组合器查询物化视图：

SELECT
  post_id,
  sum(upvotes) AS total_upvotes,
  sum(downvotes) AS total_downvotes,
  sum(score) AS total_score
FROM vote_aggregates -- Query the target table
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 │
└─────────┴───────────────┴─────────────────┴─────────────┘

描述​

示例用法​

跟踪点赞和点踩​

另请参阅​

描述

示例用法

跟踪点赞和点踩

另请参阅