SQL没有表达这种“最早一分钟”的逻辑。
如果在你的消息的开头，插入一个temperature=0的消息，那么你得到的第一个输出diff_temperature=0，不知道这种方式是否可以接受。
发件人: Chennet Steven
发送时间: Thursday, November 14, 2019 5:32 PM
收件人: user-zh@flink.apache.org; Yuan,Youjun
主题: 回复: Flink1.7.2，TableApi的自定义聚合函数中如何使用自定义状态
Yuan, 非常感谢大佬的回复和方案，我代码尝试了，这个方案的确可行，但在计算最早一分钟
","diff_temperature":0.3,"ts":11}
{"deviceid":"dev1","diff_temperature":0.1,"ts":17}
From stevenchen
webchat 38798579
________
发件人: Yuan,Youjun
发送时间: Wednesday, November 13, 2019 11:34:53 PM
收件人
: "mysink",
"type": "STDOUT"
},
"name": "demojob",
"timeType": "EVENTTIME",
"sql": "INSERT INTO mysink SELECT ts, deviceid, 2 * max_temperature -
sum_temperature AS diff_temperature FROM (
场景是一分钟为窗口计算每分钟传感器的最高温度，同时计算当前分钟与上一分钟最高温度的差值，使用flink-sql。想写一个Table的自定义UDAF，在UDAF中使用State存储上一分钟的最高温度，但是发现UDAF的open函数的FunctionContext中对于RuntimeContext是一个private，无法使用。同时DataView是
UDAF中ACC的属性，而ACC每个窗口new一个新的，无法将上一个窗口的结果通过ACC/DataView保留到下一个窗口，大佬，我所理解的对么？
请教大佬计算两个窗口之间的聚合值得差值这种场景在FlinkSql中实现的方案是啥？
From s
在flink1.9的flink-table-common中找到DataView这个接口和子类ListView,MapView，但是没有看懂如何在自定义函数中使用，
能否给个example或者是test代码的链接啊？
From stevenchen
webchat 38798579
发件人: wenlong.lwl
发送时间: Thursday, November 7, 2019 2:13:43 PM
收件人: user-zh@flink.apache.org
主题: Re: Flink1.7.2，Ta
