在基于SUM的聚合中，使用Scala选择Apache Spark Dataframe中的特定行值

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

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

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

val filteredDF = df.filter(col("column_name") === "specific_value")

val aggregatedDF = filteredDF.groupBy("grouping_column")
  .agg(sum("aggregation_column").alias("sum_value"))

aggregatedDF.show()