df.selectExpr("std(FG) as stdFG").collect()(0).getDouble(0)转换为sparkSession.sql
时间: 2024-05-16 10:13:19 浏览: 59
可以使用以下代码将该语句转换为使用Spark SQL的方式:
```
sparkSession.sql("SELECT STD(FG) as stdFG FROM df").collect()(0).getDouble(0)
```
其中,`df`是一个DataFrame对象,`sparkSession`是一个SparkSession对象。该代码将计算DataFrame `df` 中 `FG` 列的标准差,并将结果保存为名为 `stdFG` 的列。然后,使用`collect()`方法将结果转换为一个包含单个行的DataFrame对象,并使用`getDouble(0)`方法获取第一行第一列的值,即标准差。
阅读全文