Description
test("Timestamp UDF and Null value") { hiveContext.runSqlHive("CREATE TABLE ts_test (ts TIMESTAMP) STORED AS TEXTFILE") hiveContext.runSqlHive("INSERT INTO TABLE ts_test VALUES(Null)") hiveContext.udf.register("dummy", (ts: Timestamp) => ts ) val result = hiveContext.sql("SELECT dummy(ts) FROM ts_test").collect().mkString("\n") assertResult("[null]")(result) }