Commit ca97e747 authored by 王志伟's avatar 王志伟

repair bug

parent f8c7ea8c
......@@ -64,7 +64,7 @@ object app_list {
//自定义udf函数,增加dataframe 列
val code = (arg: String) => {
if (arg.getClass.getName == "java.lang.String") partition_date.toString else 0.toString
if (arg.getClass.getName == "java.lang.String") partition_date.toInt else 0.toInt
}
val addCol = udf(code)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment