我试图了解如何在 Flink 中使用 CEP 工作。例如，从页面：DataArtisans LongRides 和 Flink CEP 1.4。
我想知道 Flink CEP 应用程序中 (Scala( 代码的基本结构是什么？
应该使用哪些(强制性(部分、类、函数/方法等，按什么顺序使用？
我认为基本部分可能是：1. 模式定义2. 模式流定义(或者是否可以使用许多并行流？3. 选择定义这是对的吗？
以及如何使用"选择部分"以及如何找到有关它的更多信息？这似乎很复杂。
你写的结构基本上是正确的。您需要定义要应用该模式的事件的模式和流。然后，您应该应用select函数，该函数允许您将一些逻辑应用于构成匹配的事件。
获取 FlinkCEP 工作原理的更多信息的最佳来源是其文档。