【文件属性】:
文件名称:gostream:Go的流处理库
文件大小:27KB
文件格式:ZIP
更新时间:2021-05-05 10:57:56
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)