文件名称:flink-cep-perf:测试带窗口pattern性能
文件大小:778KB
文件格式:ZIP
更新时间:2024-05-20 10:51:16
Java
#Pattern 性能测试
测试环境
flink 版本:1.4.2
cpu:Intel(R) Core(TM) i7-4790K CPU @ 4.00GHz
内存:16G (分配给flink的)
测试背景
控制pattern的输出为1%
典型pattern测试
n分钟m次构造测试程序
Q:怎么控制pattern的输出为1%?
A:先确定pattern 的次数设置阈值是多少,然后,阈值 * 100 * 事件发送间隔时间(5s) 即为异常事件插入时间间隔。即,每发送100个事件后连续插入异常事件,插入异常事件个数大于设定的阈值。需要注意的是,设定事件次数的阈值 * 事件发送间隔时间需要小于等于窗口时间,否则pattern不会触发。
pattern代码
Pattern
【文件预览】:
flink-cep-perf-master
----src()
--------main()
----README.md(6KB)
----screenshots()
--------99298DAB-16A3-4A02-9CB5-4CE7B23EF346.png(66KB)
--------QQ20180613-103639.png(69KB)
--------QQ20180605-172012.png(82KB)
--------QQ20180612-173831.png(105KB)
--------QQ20180613-103508.png(68KB)
--------QQ20180605-153905.png(111KB)
--------less data in window.png(76KB)
--------QQ20180607-162121.png(114KB)
--------QQ20180607-164834.png(75KB)
----pom.xml(9KB)
----.gitignore(986B)