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

定义

命名空间:

Microsoft.Spark.Sql

程序集:

Microsoft.Spark.dll

包:

Microsoft.Spark v1.0.0

定义 () 数据集上要观察的指标。 此方法返回一个“观察到的”数据帧，该数据帧返回与输入相同的结果，并具有以下保证：

1. 它将计算定义聚合 (指标，) 此时流经数据集的所有数据。
2. 一旦到达完成点，它将立即报告定义的聚合列的值。完成点是查询 (批处理模式) 结束或流式处理纪元的结束。 聚合的值仅反映自上一个完成点以来处理的数据。

请注意，当前不支持连续执行。

[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