add

src/main/scala/com/winhc/bigdata/spark/utils/ChangeExtractUtils.scala

@@ -0,0 +1,36 @@
+package com.winhc.bigdata.spark.utils
+
+import org.apache.commons.lang3.StringUtils
+
+/**
+ * @Author: XuJiakai
+ * @Date: 2020/7/7 13:59
+ * @Description:
+ */
+object ChangeExtractUtils {
+  def getCurrentMap(iterable: Iterable[Map[String, String]]): (Map[String, String], Map[String, String]) = {
+    val map = iterable.map(m => (m("change_flag"), m)).toMap
+    (map("0"), map("1"))
+  }
+
+  def main(args: Array[String]): Unit = {
+  /*  val m1 = Map("a" -> "0"
+      , "b" -> "0"
+      , "change_flag" -> "0"
+    )
+    val m2 = Map("a" -> "1"
+      , "b" -> "1"
+      , "change_flag" -> "1"
+    )
+    val m3 = Map("a" -> "03"
+      , "b" -> "1"
+      , "change_flag" -> "0"
+    )
+    println(getCurrentMap(Iterable(m1, m2, m3)))*/
+
+
+   println(BaseUtil.cleanup("218.000000万人民币              "))
+//    println(StringUtils.isNoneBlank(null))
+  }
+
+}