tipark structured streaming 用sql开发实时流逻辑时怎么在sql表示时间窗口呢,例如我只需要统计最近一个小时的数据,超过一个小时的数据丢弃掉

为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。

  • 【TiDB 版本】:3.0
  • 【问题描述】:tipark structured streaming 用sql开发实时流逻辑时怎么在sql表示时间窗口呢,例如我只需要统计最近一个小时的数据,超过一个小时的数据丢弃掉

若提问为性能优化、故障排查类问题,请下载脚本运行。终端输出的打印结果,请务必全选并复制粘贴上传。

请参考spark官方文档

http://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#window-operations-on-event-time