1. //json文件
  2. //{"page_id":"87","pay_category_ids":"99","pay_product_ids":"96","city_id":5}
  3. //{"pay_category_ids":"74","city_id":0}
  4. val df = sparkSession.read.json("./src/data/test")
  5. df.show()
  6. df.rdd.foreach(row => {
  7. println("getAs: "+row.getAs[String]("page_id"))
  8. println("isNull: "+row.isNullAt(1)) //
  9. val tp = row.getAs[String]("page_id")
  10. println("==Null:",tp == null)
  11. println("getLong:", row.getString(1))
  12. })

突然想起之前项目中有些许问题未处理
今天研究一番
从row中get值时, 经常遇到空的问题
简单总结如下:
get数值类型:如果为空, 则转化为0
判空, 建议使用row.isNullAt(index)

get字符串类型:如果为空则为null
判空建议用:StringUtils.isEmpty() (出现””的情况)

总结:获取值用getAsT
判空用row.isNullAt
以及StringUtils.isEmpty()

版权声明:本文为Guanpx原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/Guanpx/p/10127015.html