// Window.Add 是非阻塞的 (如果 triggerChan 不满). // CountingWindow triggerChan size = bufferSize = 1. // Worker 协程: 从 triggerChan 读 -> 处理 ...

StreamSQL is a Spark component based on Catalyst and Spark Streaming, aiming to support SQL-style queries on data streams. Our target is to advance the progress of Catalyst as well as Spark Streaming ...