|
@@ -1,6 +1,7 @@
|
|
|
package com.winhc.bigdata.spark.utils
|
|
|
|
|
|
import org.apache.commons.lang3.StringUtils
|
|
|
+import com.winhc.bigdata.spark.implicits.CaseClass2JsonHelper._
|
|
|
import com.winhc.bigdata.spark.implicits.MapHelper._
|
|
|
|
|
|
/**
|
|
@@ -28,9 +29,9 @@ object ChangeExtractUtils {
|
|
|
|
|
|
private def getValueOrNull(value: String): String = {
|
|
|
if (StringUtils.isNotBlank(value)) {
|
|
|
- "\"" + value + "\""
|
|
|
+ value.toJson()
|
|
|
} else {
|
|
|
- "\"\""
|
|
|
+ "".toJson()
|
|
|
}
|
|
|
}
|
|
|
|