java - 如何计算非 Double 类型的 Spark 统计信息

Question

这个问题已经有答案了:

How to compute summary statistic on Cassandra table with Spark DataFrame? (3 个回答)

已关闭 7 年前。

Spark documenation包括用于计算“double”类型值的最小值、最大值、平均值统计信息的工具，但是在尝试处理 float 类型的列值时如何处理 Spark/java/cassandra 场景？

已编辑要显示分辨率:

import org.apache.spark.sql.DataFrame;
import static org.apache.spark.sql.functions.*;

DataFrame df = sqlContext.read()
        .format("org.apache.spark.sql.cassandra")
        .option("table",  "someTable")
        .option("keyspace", "someKeyspace")
        .load();

df.groupBy(col("keyColumn"))
        .agg(min("valueColumn"), max("valueColumn"), avg("valueColumn"))
        .show();

Answer 1

转换它。(double) Variable_here 将是变量的值，但为 double 值。