I'm trying to run query on some table and then storing that result in some table .
query = stream
.writeStream
.format("delta")
.foreachBatch(batch_function) \
.option('checkpointLocation', self.checkpoint_loc)
.trigger(processingTime=self.trigger_interval)
And in that query I'm first using union function and then using window function. Their I'm facing this error pyspark.sql.utils.AnalysisException: Non-time-based windows are not supported on streaming DataFrames/Datasets