ApacheFlink流媒体中有没有比较选项?

wlsrxk51  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(263)

对于我们的用例,我们希望能够在从amps服务器订阅时比较流数据[启动amps]。是否有内置函数或任何选项来比较流执行结果的先前值?

dbf7pr2w

dbf7pr2w1#

flink的特点是有状态流,并提供了几种用于检测模式和趋势的解决方案:
可以在诸如richflatmap或processfunction之类的操作符中使用state来记住有关先前事件的信息,并在处理后续事件时使用它。
cep是一个实现dsl(由有限状态机执行)的库,用于执行复杂的事件处理。
match\u recognize是flink的streamsql的一个特性,用于检测模式。

相关问题