微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

大数据_Flink_Java版_状态编程_温度跳变报警---Flink工作笔记0063

然后我们来看一下状态编程,这里我们实现一个简单的任务,就是:

我们要实现,温度跳变报警.

就是说,当两个温度值之间的温度差大于10度的时候,我们就要报警.

 

我们来做一下,这里我们新建一个

StateTest3_keyedStateApplicationCase

然后我们同样是,先把创建环境env,然后设置并行度,然后从socket流中读取数据,

获取inputStream,然后把这个inputStream通过map方法,

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐