开发者社区> 问答> 正文

Flink CEP中匹配事件提取的方法是什么?

Flink CEP中匹配事件提取的方法是什么?

展开
收起
游客k7rjnht6hbtk6 2021-12-11 21:29:36 264 0
1 条回答
写回答
取消 提交回答
  • 创建PatternStream之后,就可以应用select或者flatSelect方法,从检测到的事件序列中提取事件了。

    select()方法需要输入一个select function作为参数,每个成功匹配的事件序列都会调用它。

    select()以一个Map[String,Iterable[IN]]来接收匹配到的事件序列,其中key就是每个模式的名称,而value就是所有接收到的事件的Iterable类型。

    2021-12-11 21:29:54
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载