Trigger

org.apache.spark.sql.streaming.Trigger
See theTrigger companion trait
object Trigger

Factory methods for the supported Trigger policies.

Attributes

Companion
trait
Graph
Supertypes
class Object
trait Matchable
class Any
Self type
Trigger.type

Members list

Value members

Concrete methods

A trigger that processes all available data in (possibly) multiple micro-batches and then stops the query.

A trigger that processes all available data in (possibly) multiple micro-batches and then stops the query.

Attributes

def Continuous(interval: String): Trigger

A trigger that runs a continuous query, checkpointing at the given interval (e.g. "1 second").

A trigger that runs a continuous query, checkpointing at the given interval (e.g. "1 second").

Attributes

def ProcessingTime(interval: String): Trigger

A trigger policy that runs a micro-batch query periodically based on the processing time interval (e.g. "10 seconds").

A trigger policy that runs a micro-batch query periodically based on the processing time interval (e.g. "10 seconds").

Attributes

Deprecated methods

def Once(): Trigger

A trigger that processes all available data in a single micro-batch and then stops the query.

A trigger that processes all available data in a single micro-batch and then stops the query.

Attributes

Deprecated
true