我在试着了解Flink是否能按我所需要的方式表演。
使用cep库进行模式匹配,是否可以基于初始模式匹配设置多个流?
例如,一条消息进入并匹配模式x1,然后下一条消息匹配模式y1,下一条消息匹配模式y2,下一条消息匹配模式x2。flink是否有办法区分多组模式,并在指定的时间长度内不断查找每个模式匹配?
还是flink只是忽略了与模式下一部分不匹配的消息?如果顺序是x1>y1>y2>x2,它是否会忽略y1和y2,因为它们与x1的模式不匹配?
我在试着了解Flink是否能按我所需要的方式表演。
使用cep库进行模式匹配,是否可以基于初始模式匹配设置多个流?
例如,一条消息进入并匹配模式x1,然后下一条消息匹配模式y1,下一条消息匹配模式y2,下一条消息匹配模式x2。flink是否有办法区分多组模式,并在指定的时间长度内不断查找每个模式匹配?
还是flink只是忽略了与模式下一部分不匹配的消息?如果顺序是x1>y1>y2>x2,它是否会忽略y1和y2,因为它们与x1的模式不匹配?
暂无答案!
目前还没有任何答案,快来回答吧!