阻止,直到源中的所有可用数据都已处理并提交到接收器。 用于测试。
Syntax
processAllAvailable()
退货
None
备注
在持续到达数据的情况下,此方法可能会永久阻止。 只有在调用之前同步追加到流源的数据(也就是说,必须立即反映添加)之前, getOffset 才保证阻止此方法。
示例
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.processAllAvailable()
sq.stop()