pyspark.sql.utils。AnalysisException: Non-time-based windows不支持流媒體DataFrames /數據集

[Gaurav_784295]

pyspark.sql.utils。AnalysisException: Non-time-based windows不支持流媒體DataFrames /數據集

這個錯誤在寫可以任何一個請告訴我們如何解決它

[Aviral-Bhardwaj]

請給我們整個代碼,我們可以理解你在做什麼

或者你可以聯係我在LinkedIN和我們可以設置會議。我在我的資料LinkedIn URL

[Gaurav_784295]

我想上運行查詢一些表然後儲存,導致一些表。

查詢=流

.writeStream

.format(“δ”)

.foreachBatch batch_function \

.option (checkpointLocation, self.checkpoint_loc)

.trigger (processingTime = self.trigger_interval)

在查詢我首先使用聯盟函數,然後使用窗口函數。我麵對這個錯誤pyspark.sql.utils。AnalysisException: Non-time-based windows不支持流媒體DataFrames /數據集