Hi 如果使用CEP,可以将两个流合并成一个流,然后通过subtype根据不同的事件类型来匹配,定义CEP的Pattern,例如以下这种 DataStream<E1> s1 = ...; DataStream<E2> s2 = ...; DataStream<E> s = s1.union(s1)...; Pattern<Event, ?> = Pattern.begin("first") .subtype(E1.class) .where(...) .followedBy("second") .subtype(E2.class) .where(...)
如果使用Flink SQL,可以直接使用双流Join+窗口实现 Best, Shammon FY On Wed, May 10, 2023 at 2:24 AM casel.chen <casel_c...@126.com> wrote: > 需求:业务端实现支付功能,需要通过第三方支付平台的交易数据采用Flink > SQL来做一个实时对账,对于超过30分钟内未到达的第三方支付平台交易数据进行告警。 > 请问这个双流实时对帐场景使用Flink CEP SQL要如何实现? > > 网上找的例子都是基于单条流实现的,而上述场景会用到两条流,一个是PlatformPaymentStream,另一个是ThirdPartyPaymentStream。