数据处理 / 事件时间实验室Mooncakes 包 ↗
CORRECTION-AWARE STREAMING

让迟到的数据,
回到正确的位置。

补传、撤回、重算。沿着每一次变更,看清数据如何被修正。

POWERED BY MOONBIT
有效事件 ACTIVE EVENTS—按 ID 去重后的事实
聚合窗口 MATERIALIZED WINDOWS—事件时间中的连接关系
当前水位 WATERMARK—显式推进,绝不读取墙钟
提交版本 COMMITTED VERSION—每次原子提交仅推进一次
LIVE MATERIALIZED VIEW

事件流与窗口

会话窗口 · gap 10
活跃事件水位线窗口范围
0 / 0
⌁

载入示例中…

ORDERED INPUT

命令时间线

0
WINDOW AGGREGATES

当前聚合结果

open closing final
分组 KEY时间区间事件数SUM状态成员 ID
ATOMIC CHANGELOG

这一步发生了什么

0 条变更
⌘使用自己的数据严格 JSON 校验 · 不上传数据+
⌁ 与 CLI 使用同一核心