sumSimpleState

描述

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

示例用法

跟踪点赞和点踩

来看一个实际示例，使用一张表来跟踪帖子上的投票。对于每条帖子，我们希望维护点赞、点踩以及总体得分的累计总数。在这个用例中，使用带有 sum 的 SimpleAggregateFunction 类型非常合适，因为我们只需要存储累计总数，而不是整个聚合的完整状态。这样一来，性能会更好，并且不需要合并部分聚合状态。

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

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,
  -- sum 状态的初始值（为 'upvote' 时为 1，否则为 0）
  toUInt64(vote_type = 'upvote') AS upvotes,
  -- sum 状态的初始值（为 'downvote' 时为 1，否则为 0）
  toUInt64(vote_type = 'downvote') AS downvotes,
  -- sum 状态的初始值（'upvote' 为 1，'downvote' 为 -1）
  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 -- 查询目标表数据
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 │
└─────────┴───────────────┴─────────────────┴─────────────┘

描述​

示例用法​

跟踪点赞和点踩​

另请参阅​

描述

示例用法

跟踪点赞和点踩

另请参阅