Spark SQL DSL 中的窗口（固定、滑动等）和水印支持

Question

Spark SQL（DSL 而非 API）是否支持结构化流中的窗口化功能？ Flink 中类似的东西看起来像：

SELECT user, SUM(amount) FROM Orders GROUP BY TUMBLE(proctime,
INTERVAL '1' DAY), user

我在官方结构化流媒体网站上找到的唯一 SQL 示例如下，它不包含窗口功能示例：

df.createOrReplaceTempView("updates")

spark.sql("select count(*) from updates")  // returns another streaming DF

Answer 1

Spark 在 2.4 版本的结构化流中还没有通过 DSL 的窗口功能。版本。 Apache Flink 有这些，因为它使用Apache Calcite SQL 解析器，并且因为 Flink 正在推动 SQL 流式传输。

但是，此功能可能会在未来的版本中添加。

最佳