package emg.branchs.test
import org.apache.spark.SparkConf
import org.apache.spark.sql.SparkSession
/**
* @Auther: sss
* @Date: 2018/12/19 17:34
* @Description: 数据如: 14,2,,3,,,23 查找出值为null值的字段 填充固定的数字
*/
object RepuaceNull {
def main(args: Array[String]): Unit = {
val conf = new SparkConf().setMaster("local[*]").setAppName(this.getClass.getSimpleName)
val session = SparkSession.builder().config(conf).getOrCreate()
import session.implicits._
var files = session.read.textFile("C:\\Users\\sss\\Desktop\\asd.txt")
/** *
* 方法一 :
*
* @param args
*/
files.collect().map(str => {
val ls = str.split(",")
val lss = ls.map(x => {
if (x == null || x == "") {
(123)
} else
(x)
})
(lss(0), lss(1), lss(2), lss(3), lss(4), lss(5))
}).foreach(println)
/** *
* 方法二 : na.fill
*
* @param args 根据网上的资料 没实现 也不知道怎么回事
*/
}
}
scala数据如: 14,2,,3,,,23 查找出值为null值的字段 填充固定的数字
猜你喜欢
转载自blog.csdn.net/weixin_41804049/article/details/85229265
今日推荐
周排行