CORRECTION-AWARE STREAMING
让迟到的数据,
回到正确的位置。
补传、撤回、重算。沿着每一次变更,看清数据如何被修正。
有效事件 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 使用同一核心