Trigger.ProcessingTime Metoda
Definicja
Ważne
Niektóre informacje odnoszą się do produktu w wersji wstępnej, który może zostać znacząco zmodyfikowany przed wydaniem. Firma Microsoft nie udziela żadnych gwarancji, jawnych lub domniemanych, w odniesieniu do informacji podanych w tym miejscu.
Przeciążenia
| ProcessingTime(Int64) |
Zasady wyzwalacza, które okresowo uruchamiają zapytanie na podstawie interwału w czasie przetwarzania.
Jeśli |
| ProcessingTime(String) |
Zasady wyzwalacza, które okresowo uruchamiają zapytanie na podstawie interwału w czasie przetwarzania.
Jeśli |
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