ApacheFlink模式检测没有找到匹配项。
创始人
2024-09-05 19:30:21
0

检查模式匹配条件是否正确并确保应用程序中的数据流与模式定义的数据类型相匹配。同时,可以尝试更改匹配条件的时间窗口大小和滑动步幅,以适应数据流的处理速度和模式的复杂度。

以下是一个示例,假设我们有一个包含具有ID和温度属性的传感器读数的数据流。我们试图检测连续3个温度读数高于30度的模式。如果我们尝试运行以下代码,将会看到'Apache Flink pattern detection does not find any match”的错误:

import org.apache.flink.cep.pattern.Pattern; import org.apache.flink.cep.pattern.conditions.IterativeCondition;

Pattern pattern = Pattern.begin("start") .where(new IterativeCondition() { @Override public boolean filter(SensorReading value, Context context) throws Exception { return value.getTemperature() > 30; } }) .times(3);

因为我们没有指定模式的时间窗口大小,Flink会默认使用1秒。如果我们的数据流速度很快,或者模式需要更长时间才能出现,这可能会导致模式匹配失败。我们可以使用.within(Time.seconds(x))方法来更改时间窗口大小,其中x是我们需要的时间窗口大小(以秒为单位)。例如,如果我们希望3个连续高温温度读数模式在5秒内出现,则可以这样更改模式定义:

Pattern pattern = Pattern.begin("start") .where(new IterativeCondition() { @Override public boolean filter(SensorReading value, Context context) throws Exception { return value.getTemperature() > 30; } }) .times(3) .within(Time.seconds(5));

这将为Flink提供足够的时间来检测温度读数模式。

相关内容

热门资讯

分享个大家!丽水都莱大菠萝辅助... 分享个大家!丽水都莱大菠萝辅助,wepoker透视脚本免费app,必备教程(有挂技巧);1、构建自己...
记者发布!杭州都莱有没有挂,w... 记者发布!杭州都莱有没有挂,wepoker有辅助器吗,曝光教程(有挂秘籍);杭州都莱有没有挂是一项杭...
终于知道!微信小程序中至赣牌圈... 《终于知道!微信小程序中至赣牌圈辅助,hhpoker免费透视脚本,解说技巧(真的有挂)》 微信小程序...
重要通知!微乐江苏自建房辅助a... 您好:微乐江苏自建房辅助app这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多...
每日必备!省神麻雀辅助脚本透视... 每日必备!省神麻雀辅助脚本透视,wepoker私人局可以透视,必赢方法(有人有挂);致您一封信;亲爱...
热点推荐!微信小程序中至赣牌圈... 热点推荐!微信小程序中至赣牌圈辅助,hhpoker免费透视脚本,解密教程(有挂方式)是一款可以让一直...
总算明白!多乐跑得快辅助器,h... 总算明白!多乐跑得快辅助器,hhpoker是真的吗,普及教程(揭秘有挂)是一款可以让一直输的玩家,快...
重大来袭!超级三加一辅助,we... 重大来袭!超级三加一辅助,wepoker新号好一点吗,必赢教程(有挂细节);超级三加一辅助AI智能教...
分享实测!火神辅助免费下载,w... 您好,火神辅助免费下载这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在...
分享给玩家!九酷众游辅助,hh... 分享给玩家!九酷众游辅助,hhpoker一直输有挂吗,必胜教程(有挂实锤);一、玩家揭秘九酷众游辅助...