logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

flink09 FlinkSQL(下)

我们先实现第一版报警程序,对于一个账户,如果出现小于 $1 美元的交易后紧跟着一个大于 $500 的交易,就输出一个报警信息。2、如果表的数据量很大,随着时间的推移状态会越来越大,状态的数据时先保存在TM的内存中的,时间长了可能会出问题。每隔1分钟计算最近15分钟每个道路的车流量和平均车速(滑动事件时间窗口)当有一段sql逻辑重复时,可以定义在with语句中,减少代码量。1、flink会将之前的数

文章图片
#linq#c#
flink07 Flink状态与容错

有状态:之前的结果有状态计算:基于之前的结果进行的计算。

文章图片
#flink#大数据
到底了