Scala RDD Row空值处理：如何安全获取字段值避免空指针异常？

当直接用getInt、getString获取Row字段时，若字段为空会触发空指针异常，以下是几种安全获取的最佳方式：

• 先判断空值再取值
  用isNullAt方法先检查指定索引的字段是否为空，再根据业务需求返回目标值或默认值：

  val field_no = if (row.isNullAt(3)) 0 else row.getInt(3)
  val field_name = if (row.isNullAt(4)) "" else row.getString(4)
  

  默认值可根据场景调整，比如Int类型用-1，String类型用自定义占位符均可。

• 用Option包装安全获取
  使用getAs方法直接返回Option类型，自动处理空值，这是Scala函数式风格的推荐写法：

  val field_no: Option[Int] = row.getAs[Int](3)
  val field_name: Option[String] = row.getAs[String](4)
  

  后续可通过getOrElse快速获取值或默认值，比如field_no.getOrElse(0)，也能用模式匹配处理不同场景。

• 封装工具函数复用逻辑
  若多处需要安全获取字段，可封装通用工具函数减少重复代码：

  def safeGetInt(row: Row, index: Int, default: Int = 0): Int = {
    if (row.isNullAt(index)) default else row.getInt(index)
  }
  
  def safeGetString(row: Row, index: Int, default: String = ""): String = {
    if (row.isNullAt(index)) default else row.getString(index)
  }
  
  // 调用示例
  val field_no = safeGetInt(row, 3)
  val field_name = safeGetString(row, 4)
  

内容的提问来源于stack exchange，提问作者Sri Bharath