我正在使用Spark 2.3结构化流媒体,并尝试使用“lag”功能。但是,看起来在结构化流中不支持lag。val output = spark.sql("SELECT temperature, time, lag(temperature, 1) OVER (ORDER BY time) AS PrevTempFROM InputTable")org.apache.spark.sql.AnalysisException: Non-time-based w
我想从结构化流DataFrame构建Spark管道模型,但是遇到了一些错误。请参阅下面的代码片段和错误消息。: org.apache.spark.sql.AnalysisException: Queries with streaming sources must be executed with writeStream.start();;我们使用的是DSE Cassandra v6.0