在SparkSQL中获取Row的值，而且Row的字段允许null时，在取值的时候取到null赋值给新的变量名会报NullPointerException错误，
可以先用row.isNullAt(index)去判断该字段的值是否为空
首先上错误
修改为先初始化变量，判断row.isNullAt(6) 如果不为空就将值赋值给变量
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。
猜您在找
【Spark】Spark-空RDD判断与处理
JavaFx出现错误Caused by: java.lang.NullPointerException: Location is required的解决方法
Spark(十二)【SparkSql中数据读取和保存】
大数据开发-Spark-开发Streaming处理数据 && 写入Kafka
Spark- Spark从SFTP中读取zip压缩文件数据做计算
Spark- 数据清洗
spark-红酒-白酒评估
spark出现task不能序列化错误的解决方法
关于MySQL中的enum类型出现的错误：java.sql.SQLException: Data truncated for column 'xxxx' at row 1
spark-聚合算子aggregatebykey