Github user dongjoon-hyun commented on a diff in the pull request:
https://github.com/apache/spark/pull/20401#discussion_r164027455
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/streaming/Trigger.java ---
@@ -50,7 +50,7 @@ public static Trigger ProcessingTime(long intervalMs) {
*
* {{{
* import java.util.concurrent.TimeUnit
- * df.writeStream.trigger(ProcessingTime.create(10, TimeUnit.SECONDS))
+ * df.writeStream().trigger(Trigger.ProcessingTime(10,
TimeUnit.SECONDS))
--- End diff --
Since this is a java-friendly example, we had better use `writeStream()`.
And, `ProcessingTime.create` shows deprecation warning.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
