I tried this with udf and want to take the values to stringbuilder and then on next step I want to explode the values but can able to register the udf but unable get results val myUdf = udf { (col1: Timestamp, col2: Timestamp, col3: Int, sqlContext: SQLContext) => import sqlContext.implicits._ val sb = StringBuilder.newBuilder if (col3 == 0) { val dd = dayofmonth(date_add($"col1", 1)) val mm = month(date_add($"col1", 1)) val yy = year(date_add($"col1", 1)) val normalizedDate = concat(dd, mm, yy) sb.append(dd).append(",").append(mm).append(",").append(yy).append(",").append(normalizedDate) } else { for (i <- 2 until col3) { val dd = dayofmonth(date_add($"col1", i)) val mm = month(date_add($"col1", i)) val yy = year(date_add($"col1", i)) val normalizedDate = concat(dd, mm, yy) sb.append(dd).append(",").append(mm).append(",").append(yy).append(",").append(normalizedDate) } } sb.toString } java.lang.ClassCastException: $anonfun$1 cannot be cast to scala.Function3 at org.apache.spark.sql.catalyst.expressions.ScalaUDF.<init>(ScalaUDF.scala:106) at org.apache.spark.sql.expressions.UserDefinedFunction.apply(UserDefinedFunction.scala:56) ... 52 elided ... View more