DataFrame.WithWatermark(String, String) Metoda

Reference

Definice

Obor názvů:: Microsoft.Spark.Sql

Sestavení:: Microsoft.Spark.dll

Balíček:: Microsoft.Spark v1.0.0

Důležité

Některé informace platí pro předběžně vydaný produkt, který se může zásadně změnit, než ho výrobce nebo autor vydá. Microsoft neposkytuje žádné záruky, výslovné ani předpokládané, týkající se zde uváděných informací.

Definuje časový limit události pro tento datový rámec. Vodoznak sleduje bod v čase, před kterým předpokládáme, že žádná další data nedorazí.

public Microsoft.Spark.Sql.DataFrame WithWatermark(string eventTime, string delayThreshold);

member this.WithWatermark : string * string -> Microsoft.Spark.Sql.DataFrame

Public Function WithWatermark (eventTime As String, delayThreshold As String) As DataFrame

Parametry

eventTime: String

Název sloupce, který obsahuje čas události řádku.

delayThreshold: String

Minimální zpoždění čekání na pozdní doručení dat vzhledem k poslednímu záznamu, který byl zpracován ve formě intervalu (např. "1 minuta" nebo "5 hodin").

Návraty

DataFrame

Objekt DataFrame

Platí pro