ds-optional.scala

case class MarketingUserRefined(userId: Int, 
                                yearBirth: Int, 
                                education: String, 
                                income: Option[Int], 
                                kidhome: Option[Int], 
                                teenhome: Option[Int], 
                                dtCustomer: String,
                                recency: Option[Int])

val dsUserRefined = dfSelected
  .withColumnRenamed("id", "userId")
  .as[MarketingUserRefined]
  
val dsUserFiltered = dsUserRefined.filter(x => x.education == "Master")
dsUserFiltered.show()