DataFrame.Observe(String, Column, Column[]) Metoda

Definice

Obor názvů:

Microsoft.Spark.Sql

Sestavení:

Microsoft.Spark.dll

Balíček:

Microsoft.Spark v1.0.0

Definujte (pojmenované) metriky, které chcete sledovat v datové sadě. Tato metoda vrátí "pozorovaný" datový rámec, který vrací stejný výsledek jako vstup s následujícími zárukami:

1. Vypočítá definované agregace (metriky) pro všechna data, která v tomto okamžiku procházejí datovou sadou.
2. Jakmile dosáhneme bodu dokončení, zobrazí se hodnota definovaných agregovaných sloupců. Bod dokončení je buď konec dotazu (dávkového režimu), nebo konec epochy streamování. Hodnota agregací odráží pouze data zpracovávaná od předchozího bodu dokončení.

Upozorňujeme, že průběžné spouštění se v současné době nepodporuje.

[Microsoft.Spark.Since("3.0.0")]
public Microsoft.Spark.Sql.DataFrame Observe(string name, Microsoft.Spark.Sql.Column expr, params Microsoft.Spark.Sql.Column[] exprs);

[<Microsoft.Spark.Since("3.0.0")>]
member this.Observe : string * Microsoft.Spark.Sql.Column * Microsoft.Spark.Sql.Column[] -> Microsoft.Spark.Sql.DataFrame

Public Function Observe (name As String, expr As Column, ParamArray exprs As Column()) As DataFrame

Parametry

name

String

Pojmenované metriky k pozorování

expr

Column

Definovaná agregace k pozorování

exprs

Column[]

Definované agregace k pozorování

Návraty

DataFrame

Objekt DataFrame

Atributy

SinceAttribute