我试图了解 Flink 是否可以按照我需要的方式执行。
使用 CEP 库进行模式匹配,是否可以根据初始模式匹配设置多个流?
例如,一条消息进来并匹配模式 x1,然后下一条消息匹配模式 y1,接下来是 y2,下一个是 x2。Flink 有没有办法区分多组模式,并在指定的时间长度内不断寻找每个模式匹配?
还是 Flink 只是忽略与模式下一部分不匹配的消息?如果顺序是 x1 > y1 > y2 > x2,是否会因为不匹配 x1 的模式而忽略 y1 和 y2?
我试图了解 Flink 是否可以按照我需要的方式执行。
使用 CEP 库进行模式匹配,是否可以根据初始模式匹配设置多个流?
例如,一条消息进来并匹配模式 x1,然后下一条消息匹配模式 y1,接下来是 y2,下一个是 x2。Flink 有没有办法区分多组模式,并在指定的时间长度内不断寻找每个模式匹配?
还是 Flink 只是忽略与模式下一部分不匹配的消息?如果顺序是 x1 > y1 > y2 > x2,是否会因为不匹配 x1 的模式而忽略 y1 和 y2?