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