在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