对于我们的用例,我们希望能够在从amps服务器订阅时比较流数据[启动amps]。是否有内置函数或任何选项来比较流执行结果的先前值?
dbf7pr2w1#
flink的特点是有状态流,并提供了几种用于检测模式和趋势的解决方案:可以在诸如richflatmap或processfunction之类的操作符中使用state来记住有关先前事件的信息,并在处理后续事件时使用它。cep是一个实现dsl(由有限状态机执行)的库,用于执行复杂的事件处理。match\u recognize是flink的streamsql的一个特性,用于检测模式。
1条答案
按热度按时间dbf7pr2w1#
flink的特点是有状态流,并提供了几种用于检测模式和趋势的解决方案:
可以在诸如richflatmap或processfunction之类的操作符中使用state来记住有关先前事件的信息,并在处理后续事件时使用它。
cep是一个实现dsl(由有限状态机执行)的库,用于执行复杂的事件处理。
match\u recognize是flink的streamsql的一个特性,用于检测模式。