文件名称:gostream:Go的流处理库
文件大小:27KB
文件格式:ZIP
更新时间:2024-05-25 04:44:36
golang cep stream-processing complex-event-processing Go
流 Go的流处理库 去做 窗户 长度窗 LengthBatchWindow 时间窗 TimeBatchWindow 在哪里 EqualsType,NotEqualsType 等于,不等于 大于小于 通过...分组 功能 最大,最小,中位数 计数,总和,平均值 投 作为 有 选择 清楚的 按订单 极限,第一,最后 工具 Lexer 解析器 安装 go get github.com/itsubaki/gostream 例子 type LogEvent struct { Time time. Time Level int Message string } // select count(*) from LogEvent.time(10sec) where Level > 2 w := window . NewTime ( Lo
【文件预览】:
gostream-main
----.gitignore(18B)
----go.mod(45B)
----gostream_test.go(1KB)
----Makefile(80B)
----pkg()
--------lexer()
--------event()
--------statement()
--------clause()
--------parser()
--------window()
----LICENSE(1KB)
----.github()
--------workflows()
----README.md(2KB)