|
override def handle(rowkey: String, oldMap: Map[String, String], newMap: Map[String, String]): (String, String, String, Map[String, String], String, String, String, String, Map[String, String]) =
|
|
override def handle(rowkey: String, oldMap: Map[String, String], newMap: Map[String, String]): (String, String, String, Map[String, String], String, String, String, String, Map[String, String]) =
|
|
super.handle(rowkey, oldMap, newMap.map(m=>{
|
|
super.handle(rowkey, oldMap, newMap.map(m=>{
|
|
m._1->m._2.replace(",","、")
|
|
m._1->m._2.replace(",","、")
|