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

flink07 Flink状态与容错
有状态:之前的结果有状态计算:基于之前的结果进行的计算。

到底了







