Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19984#discussion_r157124515
--- 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))
+ * }}}
+ *
+ * @since 2.3.0
+ */
+ public static Trigger Continuous(long interval, TimeUnit timeUnit) {
+ return ContinuousTrigger.create(interval, timeUnit);
+ }
+
+ /**
+ * (Scala-friendly)
+ * A trigger that continuously processes streaming data, asynchronously
checkpointing at
+ * the specified interval.
+ *
+ * {{{
+ * import scala.concurrent.duration._
+ * df.writeStream.trigger(Trigger.Continuous(10.seconds))
+ * }}}
+ * @since 2.2.0
+ */
+ public static Trigger Continuous(Duration interval) {
+ return ContinuousTrigger.apply(interval);
+ }
+
+ /**
+ * A trigger that continuously processes streaming data, asynchronously
checkpointing at
+ * the specified interval.
+ *
+ * {{{
+ * df.writeStream.trigger(Trigger.Continuous("10 seconds"))
+ * }}}
+ * @since 2.2.0
--- End diff --
2.3.0?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
