在PySpark中,有没有其他方法可以应用静态框架和结构化流框架之间的联合?
iecba09b1#
不,这是不可能的。不过,使用带有批处理功能的foreachBatch()可以满足这一要求。参见https://docs.databricks.com/en/structured-streaming/foreach.html
foreachBatch()
1条答案
按热度按时间iecba09b1#
不,这是不可能的。
不过,使用带有批处理功能的
foreachBatch()
可以满足这一要求。参见https://docs.databricks.com/en/structured-streaming/foreach.html