base.scala

val spark = SparkSession
  .builder
  .appName("MyAwesomeApp")
  .master("local[*]")
  .getOrCreate()

import spark.implicits._

val groceries = spark.read
  .option("inferSchema", "true")
  .option("header", "true")
  .csv("some-data.csv")

val sumOfFruits = groceries
  .filter($"type" === "fruit")
  .withColumn("normalized_name", lower($"name"))
  .groupBy("normalized_name")
  .agg(
    sum(($"quantity")).as("sum")
  )

val fruits = groceries.filter($"type" === "fruit")

val normalizedFruits = fruits.withColumn("normalized_name", lower($"name"))

val sumOfFruits = normalizedFruits
  .groupBy("normalized_name")
  .agg(
    sum(($"quantity")).as("sum")
  )

sumOfFruits.show()