Flink SQL CEP如何处理双(多)流输入?

2023-05-11 Thread casel.chen
请问Flink SQL CEP只能处理单流输入吗?网上看到的例子都是在同一个输入流中进行CEP处理,有没有双(多)输入流下使用CEP处理的例子?谢谢!

flink 状态设置

2023-05-11 Thread 小昌同学
各位老师好,我这边使用的flink sql是" select funcId,funcIdDesc,serverIp,cast(min(maxTime-minTime) as varchar(200)) as minTime,pk from ( select a.funcId as funcId , a.funcIdDesc as funcIdDesc, a.serverIp as serverIp, b.outTime as maxTime, a.outTime as minTime, concat(a.funcId,a.serverIp) as pk fro

回复:Flink SQL CEP如何处理双(多)流输入?

2023-05-11 Thread CloudFunny
双流join? 回复的原邮件 | 发件人 | casel.chen | | 发送日期 | 2023年05月12日 11:52 | | 收件人 | user-zh@flink.apache.org | | 主题 | Flink SQL CEP如何处理双(多)流输入? | 请问Flink SQL CEP只能处理单流输入吗?网上看到的例子都是在同一个输入流中进行CEP处理,有没有双(多)输入流下使用CEP处理的例子?谢谢!