Trigger.ProcessingTime Method

Definition

Namespace:

Microsoft.Spark.Sql.Streaming

Assembly:

Microsoft.Spark.dll

Package:

Microsoft.Spark v1.0.0

Overloads

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.

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.

public static Microsoft.Spark.Sql.Streaming.Trigger ProcessingTime (long intervalMs);

static member ProcessingTime : int64 -> Microsoft.Spark.Sql.Streaming.Trigger

Public Shared Function ProcessingTime (intervalMs As Long) As Trigger

Parameters

intervalMs

Int64

Milliseconds

Returns

Trigger

Trigger Object

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.

public static Microsoft.Spark.Sql.Streaming.Trigger ProcessingTime (string interval);

static member ProcessingTime : string -> Microsoft.Spark.Sql.Streaming.Trigger

Public Shared Function ProcessingTime (interval As String) As Trigger

Parameters

interval

String

string representation for interval. eg. "10 seconds"

Returns

Trigger

Trigger Object