Share via

Trigger Class

  • Reference

Definition

Namespace:
Microsoft.Spark.Sql.Streaming
Assembly:
Microsoft.Spark.dll
Package:
Microsoft.Spark v1.0.0

Policy used to indicate how often results should be produced by a StreamingQuery

public sealed class Trigger
type Trigger = class
Public NotInheritable Class Trigger
Inheritance
Object
Trigger

Methods

Continuous(Int64)

A trigger that continuously processes streaming data, asynchronously checkpointing at the specified interval.
Continuous(String)

A trigger that continuously processes streaming data, asynchronously checkpointing at the specified interval.
Once()

A trigger that process only one batch of data in a streaming query then terminates the query.
ProcessingTime(Int64)

A trigger policy that runs a query periodically based on an interval in processing time. If interval is 0, the query will run as fast as possible.
ProcessingTime(String)

A trigger policy that runs a query periodically based on an interval in processing time. If interval is effectively 0, the query will run as fast as possible.

Applies to