基于Spark Dataframe中的条件的行中单列总和

import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._

val spark = SparkSession.builder()
  .appName("Spark Dataframe Sum")
  .master("local")
  .getOrCreate()

val df = spark.read
  .format("csv")
  .option("header", "true")
  .load("path/to/your/data.csv")

val filteredDf = df.filter(col("condition_column") === "condition_value")

val sumResult = filteredDf.select(sum(col("sum_column"))).collect()(0)(0)

println("Sum of filtered column: " + sumResult)