pyspark.sql.utils。AnalysisException: Non-time-based windows不支持流媒體DataFrames /數據集
這個錯誤在寫可以任何一個請告訴我們如何解決它
我想上運行查詢一些表然後儲存,導致一些表。
查詢=流
.writeStream
.format(“δ”)
.foreachBatch batch_function \
.option (checkpointLocation, self.checkpoint_loc)
.trigger (processingTime = self.trigger_interval)
在查詢我首先使用聯盟函數,然後使用窗口函數。我麵對這個錯誤pyspark.sql.utils。AnalysisException: Non-time-based windows不支持流媒體DataFrames /數據集