Looks like Spark Session has only implementation for UDAF but not for UDF.
Is it a bug or some work around is there ?
T.Gaweda has opened JIRA for this. SPARK-25334
Thanks,
Swapnil
On Tue, Sep 4, 2018 at 4:20 PM Swapnil Chougule
wrote:
> Created one project 'spark-udf' & written hive udf as bel
Created one project 'spark-udf' & written hive udf as below:
package com.spark.udf
import org.apache.hadoop.hive.ql.exec.UDF
class UpperCase extends UDF with Serializable {
def evaluate(input: String): String = {
input.toUpperCase
}
Built it & created jar for it.
