本文介绍Spark SQL流式处理支持的窗口函数及其时间属性。
窗口函数
时间属性
Spark SQL支持Event Time时间属性,对数据进行窗口内聚合。
Event Time:事件时间,通常是您提供在Schema中数据最原始的创建时间。
说明
查询已存在的时间窗口时,窗口函数自动生成window
列,包含窗口的起止时间信息,即window.start
和window.end
。
本文介绍Spark SQL流式处理支持的窗口函数及其时间属性。
Spark SQL支持Event Time时间属性,对数据进行窗口内聚合。
Event Time:事件时间,通常是您提供在Schema中数据最原始的创建时间。
查询已存在的时间窗口时,窗口函数自动生成window
列,包含窗口的起止时间信息,即window.start
和window.end
。