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

unv*_*dim 6 pyspark databricks spark-structured-streaming delta-lake

Databricks文档中的所有示例均采用 Scala 语言。无法从 PySpark 找到如何使用此触发器类型。是否有等效的 API 或解决方法?

Ale*_*Ott 6

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

.trigger(availableNow=True)
Run Code Online (Sandbox Code Playgroud)