cep应用中scala代码的基本结构

gg0vcinb  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(325)

我试着去理解如何在Flink的作品中进行cep。例如,来自页面:dataartisans longrides和flink cep 1.4。
我想知道flink cep应用程序中(scala)代码的基本结构是什么?
应该使用哪些(必需的)部分、类、函数/方法等,以及使用顺序如何?
我认为基本的部分可以是:1。图案定义2。模式流定义(或者是否可以使用多个并行流?)。选择定义正确吗?
以及如何使用“选择部分”以及如何找到有关它的更多信息?这似乎很复杂。

zvms9eto

zvms9eto1#

你写的结构基本上是正确的。您需要定义要应用该模式的模式和事件流。那你应该申请 select 函数,它允许您对构成匹配的事件应用一些逻辑。
获取flinkcep如何工作的更多信息的最佳来源是它的文档。

相关问题