Github user dongjoon-hyun commented on a diff in the pull request:
https://github.com/apache/spark/pull/20401#discussion_r164027523
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/streaming/Trigger.java ---
@@ -66,7 +66,7 @@ public static Trigger ProcessingTime(long interval,
TimeUnit timeUnit) {
*
* {{{
* import scala.concurrent.duration._
- * df.writeStream.trigger(ProcessingTime(10.seconds))
+ * df.writeStream.trigger(Trigger.ProcessingTime(10.seconds))
--- End diff --
Also, `Trigger.ProcessingTime` supercedes `ProcessingTime`.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
