Trigger.ProcessingTime Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Overloads
ProcessingTime(Int64) |
A trigger policy that runs a query periodically based on an interval
in processing time.
If |
ProcessingTime(String) |
A trigger policy that runs a query periodically based on an interval
in processing time.
If |
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 Object
Applies to
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 Object