Spark- SparkSQL中 Row.getLong 出现NullPointerException错误的处理方法

在SparkSQL中获取Row的值,而且Row的字段允许null时,在取值的时候取到null赋值给新的变量名会报NullPointerException错误,

可以先用row.isNullAt(index)去判断该字段的值是否为空

首先上错误

修改为先初始化变量,判断row.isNullAt(6) 如果不为空就将值赋值给变量

 

相关文章