Trigger.ProcessingTime Yöntem

Tanım

Aşırı Yüklemeler

ProcessingTime(Int64)

İşlem süresindeki bir aralığı temel alarak bir sorguyu düzenli aralıklarla çalıştıran bir tetikleyici ilkesi. 0 ise interval , sorgu mümkün olan en hızlı şekilde çalıştırılır.

ProcessingTime(String)

İşlem süresindeki bir aralığı temel alarak bir sorguyu düzenli aralıklarla çalıştıran bir tetikleyici ilkesi. interval Etkin bir şekilde 0 ise, sorgu mümkün olan en hızlı şekilde çalıştırılır.

ProcessingTime(Int64)

İşlem süresindeki bir aralığı temel alarak bir sorguyu düzenli aralıklarla çalıştıran bir tetikleyici ilkesi. 0 ise interval , sorgu mümkün olan en hızlı şekilde çalıştırılır.

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

Parametreler

intervalMs
Int64

Milisaniye

Döndürülenler

Tetikleyici Nesnesi

Şunlara uygulanır

ProcessingTime(String)

İşlem süresindeki bir aralığı temel alarak bir sorguyu düzenli aralıklarla çalıştıran bir tetikleyici ilkesi. interval Etkin bir şekilde 0 ise, sorgu mümkün olan en hızlı şekilde çalıştırılır.

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

Parametreler

interval
String

aralık için dize gösterimi. Örneğin "10 saniye"

Döndürülenler

Tetikleyici Nesnesi

Şunlara uygulanır