我有一个基于时间序列存储模型的架构。我现在正在尝试将一些聚合管道转换为MapReduce模型，但我不知道MapReduce中“展开”的等效条件是什么。这是我的模型：
time series schema
例如，如何将每个“ SITE_ID”中“ val_per_day_dt”中的所有值相加？