问题描述
我如何恢复数据:每15分钟我要恢复过去15分钟的数据。 如果我的时间是14H:00,则必须将数据从13H:45恢复到14H。
我尝试过
Dataset<Row> df = mydf
.withWatermark("timestamp","15 minutes")
.groupBy(window(col("timestamp"),"15 minutes","15 minutes"),col("value")).count();
但它不起作用,请有想法的人,谢谢
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)