Trigger.ProcessingTime Metoda

Definicja

Przeciążenia

ProcessingTime(Int64)

Zasady wyzwalacza, które okresowo uruchamiają zapytanie na podstawie interwału w czasie przetwarzania. Jeśli interval wartość wynosi 0, zapytanie zostanie uruchomione tak szybko, jak to możliwe.

ProcessingTime(String)

Zasady wyzwalacza, które okresowo uruchamiają zapytanie na podstawie interwału w czasie przetwarzania. Jeśli interval wartość wynosi 0, zapytanie zostanie uruchomione tak szybko, jak to możliwe.

ProcessingTime(Int64)

Zasady wyzwalacza, które okresowo uruchamiają zapytanie na podstawie interwału w czasie przetwarzania. Jeśli interval wartość wynosi 0, zapytanie zostanie uruchomione tak szybko, jak to możliwe.

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

Parametry

intervalMs
Int64

Milisekund

Zwraca

Wyzwalacz, obiekt

Dotyczy

ProcessingTime(String)

Zasady wyzwalacza, które okresowo uruchamiają zapytanie na podstawie interwału w czasie przetwarzania. Jeśli interval wartość wynosi 0, zapytanie zostanie uruchomione tak szybko, jak to możliwe.

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

Parametry

interval
String

reprezentacja ciągu dla interwału. np. "10 sekund"

Zwraca

Wyzwalacz, obiekt

Dotyczy