【文件属性】：
文件名称：Freshet-Old:用于 Apache Samza 的基于 CQL 的 Clojure DSL
文件大小：7.31MB
文件格式：ZIP
更新时间：2021-06-28 13:04:27
Java
新鲜
用于 Apache Samza 的基于的 Clojure DSL。
Freshet 是基于 SQL [1] 扩展支持连续查询的 Kappa 架构的完整实现的第一步。 Freshet 在 Apache Samza 之上实现了 CQL 的一个子集（选择、窗口化、聚合）。 Freshet 实现了RStream和IStream关系到流运算符，基于元组和时间的滑动窗口将流转换为关系，将基本关系转换为关系运算符以实现业务逻辑。 遵循 CQL，Freshet 使用插入/删除流来模拟瞬时关系。
Freshet 查询 DSL
定义流
( defstream wikipedia-feed
( stream-fields [ :title :string
:user :string
:diff-bytes :inte