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提供足够的时间来检测温度读数模式。

相关内容

热门资讯

实测教程!四川麻将口诀顺口溜,... 实测教程!四川麻将口诀顺口溜,雀神广东定制插件辅助(果然是真的有挂)1、下载好雀神广东定制插件辅助透...
推荐十款!同乡游辅助软件,hh... 推荐十款!同乡游辅助软件,hh poker透视器下载,大神讲解(有挂方式);推荐十款!同乡游辅助软件...
终于清楚!闲来透视辅助器最新版... 终于清楚!闲来透视辅助器最新版,晃晃辅助软件(都是存在有挂)在进入闲来透视辅助器最新版软件靠谱后,参...
科普常识!乐达app辅助,hh... 科普常识!乐达app辅助,hhpoker免费透视脚本,力荐教程(有挂教学);1、不需要AI权限,帮助...
一分钟揭秘!wepoker破解... 一分钟揭秘!wepoker破解版内购,九九联盟辅助神器(总是是有挂)一、九九联盟辅助神器可以开透视的...
今日科普!朋朋政和软件辅助器,... 今日科普!朋朋政和软件辅助器,wepoker透视脚本苹果版,分享教程(确实有挂);一、朋朋政和软件辅...
最新研发!随意玩辅助器视频有挂... 最新研发!随意玩辅助器视频有挂,欢游互动辅助(其实是有挂)1、实时随意玩辅助器视频有挂透视辅助更新:...
今日科普!八闽福建辅助,wpk... 今日科普!八闽福建辅助,wpk软件是正规的吗,技巧教程(新版有挂);八闽福建辅助是一项八闽福建辅助软...
揭秘一下!科乐天天踢填大坑辅助... 揭秘一下!科乐天天踢填大坑辅助,德友汇辅助器(其实是真的有挂)小薇(辅助器软件下载)致您一封信;亲爱...
科技新动态!内蒙老友辅助,we... 科技新动态!内蒙老友辅助,werplan有挂吗,新版2025教程(有挂讲解)是一款可以让一直输的玩家...