集成与管道🔥8.0

StreamSQL v1.3.0 发布:流-流 JOIN,补齐双流窗口化关联

OSCHINA·2026/10/9 03:13:36🔗 原文

📋总体概括

实时流处理引擎StreamSQL发布v1.3.0,补齐stream-stream JOIN能力,完成Over分析函数(v1.1)、CEP模式识别(v1.2)之后状态化算子三件套的最后一块。新功能支持两条实时流按主键关联,事件时间差不超过WITHIN才算匹配,并提供LEFT无匹配补NULL做缺席检测、3条以上流级联关联、EmitTo多流喂数等特性。全部变更为additive,存量查询无需修改代码,平滑升级。

⚡关键信息

  • ▸StreamSQL v1.3.0发布stream-stream JOIN,完成v1.1 Over函数、v1.2 CEP之后的状态化算子三件套
  • ▸新JOIN要求两条实时流按主键关联,且事件时间相差不超过WITHIN才算匹配
  • ▸LEFT JOIN无匹配时补NULL,用于缺席检测场景
  • ▸支持3条以上流级联关联及EmitTo多流喂数
  • ▸全部新增为additive变更,不写WITHIN的存量查询无需改代码

🔥犀利点评

流-流JOIN是流处理引擎从玩具走向生产的关键分水岭——状态管理、乱序、水位线乱成一锅粥,敢做才算入场。StreamSQL用三个版本补齐Flink早就有三件套,路线清晰但本质是补课而非超越,真正考验在JOIN的状态TTL和内存治理,发布稿只字未提。additive兼容是务实之举,但缺席检测补NULL这种细节才是打动用户的地方。

本文由本站自动聚合,以下为原始来源:前往 OSCHINA 阅读全文 →