Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19984#discussion_r157135337
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/streaming/Trigger.java ---
@@ -95,4 +96,57 @@ public static Trigger ProcessingTime(String interval) {
public static Trigger Once() {
return OneTimeTrigger$.MODULE$;
}
+
+ /**
+ * A trigger that continuously processes streaming data, asynchronously
checkpointing at
+ * the specified interval.
+ *
+ * @since 2.3.0
+ */
+ public static Trigger Continuous(long intervalMs) {
+ return ContinuousTrigger.apply(intervalMs);
+ }
+
+ /**
+ * A trigger that continuously processes streaming data, asynchronously
checkpointing at
+ * the specified interval.
+ *
+ * {{{
+ * import java.util.concurrent.TimeUnit
+ * df.writeStream.trigger(ProcessingTime.create(10, TimeUnit.SECONDS))
--- End diff --
`Trigger.Continuous(10, TimeUnit.SECONDS)` instead of
`ProcessingTime.create(10, TimeUnit.SECONDS)`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
