【发布时间】：2018-12-12 12:47:06
【问题描述】：
对于我们的用例，我们希望能够在从 AMPS 服务器订阅时比较流数据 [CRANK UP THE AMPS]。是否有内置函数或任何选项来比较流执行结果的先前值？
【问题讨论】：
-
问题不清楚。请关注stackoverflow.com/help/how-to-ask
标签： scala streaming apache-flink flink-streaming
【发布时间】：2018-12-12 12:47:06
【问题描述】：
Flink 具有stateful streaming，并提供多种检测模式和趋势的解决方案：
- 您可以在 RichFlatMap 或 ProcessFunction 等运算符中使用状态来记住有关先前事件的信息，并在处理后续事件时使用它。
- CEP 是一个实现 DSL（由有限状态机执行）以进行复杂事件处理的库。
- MATCH_RECOGNIZE 是 Flink 的 Stream SQL 的一个特性，用于检测模式。
【讨论】：