我试着去理解如何在Flink的作品中进行cep。例如,来自页面:dataartisans longrides和flink cep 1.4。
我想知道flink cep应用程序中(scala)代码的基本结构是什么?
应该使用哪些(必需的)部分、类、函数/方法等,以及使用顺序如何?
我认为基本的部分可以是:1。图案定义2。模式流定义(或者是否可以使用多个并行流?)。选择定义正确吗?
以及如何使用“选择部分”以及如何找到有关它的更多信息?这似乎很复杂。
我试着去理解如何在Flink的作品中进行cep。例如,来自页面:dataartisans longrides和flink cep 1.4。
我想知道flink cep应用程序中(scala)代码的基本结构是什么?
应该使用哪些(必需的)部分、类、函数/方法等,以及使用顺序如何?
我认为基本的部分可以是:1。图案定义2。模式流定义(或者是否可以使用多个并行流?)。选择定义正确吗?
以及如何使用“选择部分”以及如何找到有关它的更多信息?这似乎很复杂。
1条答案
按热度按时间zvms9eto1#
你写的结构基本上是正确的。您需要定义要应用该模式的模式和事件流。那你应该申请
select
函数,它允许您对构成匹配的事件应用一些逻辑。获取flinkcep如何工作的更多信息的最佳来源是它的文档。