import org.apache.spark.sql.functions.{udf, struct} val reduceItems = (items: Row) => { 10 } val reduceItemsUdf = udf(reduceItems) h.select(reduceItemsUdf(struct("*")).as("r")).show()