开发者社区 问答 正文

Flink CEP如何进行进行分组匹配?

Flink CEP如何进行进行分组匹配?

展开
收起
游客k7rjnht6hbtk6 2021-12-12 09:30:39 455 分享 版权
1 条回答
写回答
取消 提交回答
  • val loginFailDataPattern = CEP.pattern(loginEventStream.keyBy(_.userId), loginFailPattern)
    
    2021-12-12 09:30:56
    赞同 展开评论