Spark Connect for Scala 3/org.apache.spark/org.apache.spark.sql/org.apache.spark.sql.streaming/Trigger

Trigger

org.apache.spark.sql.streaming.Trigger

See theTrigger companion object

sealed trait Trigger

A policy for how often a streaming query produces results, set with DataStreamWriter.trigger(...). Mirrors org.apache.spark.sql.streaming.Trigger.

 df.writeStream.trigger(Trigger.ProcessingTime("10 seconds"))
 df.writeStream.trigger(Trigger.AvailableNow())
 df.writeStream.trigger(Trigger.RealTime("5 minutes"))

Attributes

Companion: object
Graph
Supertypes: class Object

trait Matchable

class Any

In this article

Generated with