DataFrame.Observe(String, Column, Column[]) 方法

定義

命名空間:

Microsoft.Spark.Sql

組件:

Microsoft.Spark.dll

套件:

Microsoft.Spark v1.0.0

定義名為) 計量的 (，以觀察資料集上的計量。 這個方法會傳回 「觀察到的」DataFrame，其會傳回與輸入相同的結果，並保證如下：

1. 它會計算在該時間點流經資料集的所有資料上，所定義的匯總 (計量) 。
2. 它會在到達完成點時立即報告已定義匯總資料行的值。完成點是查詢 (批次模式的結尾，) 或串流 Epoch 的結尾。 匯總的值只會反映自上一個完成點以來處理的資料。

請注意，目前不支援持續執行。

[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

參數

name

String

要觀察的具名計量

expr

Column

要觀察的已定義匯總

exprs

Column[]

要觀察的已定義匯總

傳回

DataFrame

DataFrame 物件

屬性

SinceAttribute