小编xia*_*ing的帖子

如何foreach在 Python Spark 结构化流中使用以触发输出操作。

query = wordCounts\
    .writeStream\
    .outputMode('update')\
    .foreach(func)\
    .start()

def func():
    ops(wordCounts)