Trigger.AvailableNow 用于 PySpark (Databricks) 中的 Delta 源流查询

Trigger.AvailableNow for Delta source streaming queries in PySpark (Databricks)

Databricks documentation 中的所有示例都在 Scala 中。无法从 PySpark 找到如何使用此触发器类型。是否有等效的 API 或解决方法?

Python 实现错过了 Spark 3.2 版本,因此它将仅包含在 Spark 3.3 中(对于 OSS 版本)。在 Databricks 上,它作为 DBR 10.3(或 10.2?)的一部分发布,可以按如下方式使用:

.trigger(availableNow=True)