K
override def convertSource(df:DataFrame,convert: A => Option[B])(implicit sparkSession: SparkSession): DataFrame = {
import sparkSession.implicits._
df.as[A].flatMap(convert)).toDF()
}
}
}
Size: a a a
K
K
Oℕ
GP
GP
K
GP
K
Oℕ
K
K
GP
K
ZM
Oℕ
K
K
Oℕ
R
Oℕ