Flink难点：彻底明白CEP3：独立模式【Patterns】操作Pattern Operation
问题导读1.独立模式有哪些条件？
2.循环模式模式该如何停止？
3.subtype的作用是什么？
上一篇：
Flink难点：彻底明白CEP2，条件分类
http://www.aboutyun.com/forum.php?mod=viewthread&tid=27295
1.where(condition)
定义当前模式的条件。 要匹配模式，事件必须满足条件。
pattern.where(event => ... /* some condition */)
pattern.where(new IterativeCondition<Event>() {
@Override
public boolean filter(Event value, Context ctx) throws Exception {
return ... // some condition
}
});
2.or(condition)
添加与现有条件进行“或”运算的新条件。 仅当事件至少通过其中一个条件时，才能匹配该模式：
pattern.where(event => ... /* some condition */)
.or(event => ... /* alternative condition */)
pattern.where(new IterativeCondition<Event>() {
@Override
public boolean filter(Event value, Context ctx) throws Exception {
return ... // some condition
}
}).or(new IterativeCondition<Event>() {
@Override
public boolean filter(Event value, Context ctx) throws Exception {
return ... // alternative condition
}
});
3.until(condition)
指定循环模式的停止条件。 意味着如果匹配给定条件的事件发生，则不再接受该模式中的事件。
仅适用于oneOrMore（）
注意：它允许在基于事件的条件下清除相应模式的状态。
pattern.oneOrMore().until(new IterativeCondition<Event>() {
@Override
public boolean filter(Event value, Context ctx) throws Exception {
return ... // alternative condition
}
});
pattern.oneOrMore().until(event => ... /* some condition */)
4.subtype(subClass)
定义当前模式的子类型条件。 如果事件属于此子类型，则事件只能匹配该模式：
pattern.subtype(classOf)
pattern.subtype(SubEvent.class);
5.oneOrMore()
指定此模式至少需要出现一次匹配事件。
默认情况下，使用宽松的内部连续性（在后续事件之间）。 有关内部连续性的更多信息，请参阅连续。
注意：建议使用until（）或within（）来启用状态清除
pattern.oneOrMore();
pattern.oneOrMore()
6.timesOrMore(#times)
指定此模式至少需要#times【次数】出现匹配事件。
默认情况下，使用宽松的内部连续性（在后续事件之间）。 有关内部连续性的更多信息，请参阅连续。
pattern.timesOrMore(2)
pattern.timesOrMore(2);
7.times(#ofTimes)
指定此模式需要匹配事件的确切出现次数。
默认情况下，使用宽松的内部连续性（在后续事件之间）。 有关内部连续性的更多信息，同6。
pattern.times(2);
pattern.times(2)
8.times(#fromTimes, #toTimes)
指定此模式期望在匹配事件的#fromTimes和#toTimes之间出现。
默认情况下，使用宽松的内部连续性（在后续事件之间）。 有关内部连续性的更多信息，同6。
pattern.times(2, 4)
pattern.times(2, 4);
9.optional()
指定此模式是可选的，即根本不会发生或则发生。 这适用于所有上述量词。
pattern.oneOrMore().optional();
pattern.oneOrMore().optional()
10.greedy()
指定此模式是贪婪的，即它将尽可能多地重复。 这仅适用于量词，目前不支持组（group ）模式。
pattern.oneOrMore().greedy();
pattern.oneOrMore().greedy()
最新经典文章，欢迎关注公众号http://www.aboutyun.com/data/attachment/forum/201903/18/215536lzpn7n3u7m7u90vm.jpg
加入About云知识星球，获取更多实用资料
http://www.aboutyun.com/data/attachment/forum/201906/10/162109faj7o1z2qobr83jd.png
感谢分享 写的非常棒，学习了 1.独立模式有哪些条件？
- where(condition)
- or(condition)
- until(condition)
- subtype(subClass)
- oneOrMore()
- timesOrMore(#times)
- times(#ofTimes)
- times(#fromTimes, #toTimes)
- optional()
- greedy()
2.循环模式模式该如何停止？
- until，within（）
3.subtype的作用是什么？
- 将接受事件的类型限制为初始事件类型的子类型。
页:
[1]