用途:该技能面向 RisingWave 的 schema 设计、物化视图编写、source/sink 配置、流式 SQL 性能优化与慢查询排查,提供 14 条可执行的审查规则。
主要能力:规则按优先级分为五类。Schema 设计(schema-)含 SOURCE 与 TABLE 选择、APPEND ONLY 用于不可变流、watermark 放置位置;物化视图(mv-)含窗口查询使用 EOWC、大表非阻塞 DDL、MV 中 ORDER BY 的局限;流式 SQL(stream-)含 TUMBLE/HOP/SESSION 时间窗口、两步 CDC 设置、流与 CDC 表的时间连接;Sink 配置(sink-)含 snapshot=false 防止回填重复、force_compaction 降低输出量;性能(perf-)含共享 Kafka source、MV 索引、MV 并行度调优。
使用方式:先阅读对应审查类型的规则文件,再将规则应用到待审查的设计或代码,最后说明违规点、影响与修复方式。
关键要点:CDC 需用 TABLE,SOURCE 用于仅追加流;watermark 应在摄入点定义而非 MV;窗口最终结果用 EOWC;大表建 MV 前设 SET BACKGROUND_DDL=true;流式窗口用 TUMBLE/HOP/SESSION 而非 date_trunc;CDC 采用 CREATE SOURCE 后 CREATE TABLE ... FROM source 两步;流与 CDC 表用 FOR SYSTEM_TIME AS OF 连接;为已有 MV 添加 sink 时用 snapshot = false;高基数 upsert sink 用 force_compaction = true;同一 Kafka topic 的多个 MV 应共享 source;在 WHERE/JOIN 谓词涉及的 MV 列上建索引;高吞吐 MV 提高并行度。
适用场景:RisingWave 流处理项目的设计评审、SQL 代码审查与性能调优。限制:资料未提供具体版本要求、完整示例代码及每条规则的详细说明,需查阅对应规则文件。