该方法提供了很好的扩展性,也支持复杂类型的特殊情况,包括内嵌的List,或者内嵌的Json对象等都支持。很强大,能让我偷懒~~~~
val news = rdd.map(_._2).map( x => JsonMapper.buildNormalMapper.fromJson(x.trim, classOf[News])) val sqlContext = new SQLContext(sc) val newsDF = sqlContext.createDataFrame(news,classOf[News])这样子就很舒服,一个一个的去new,然后去set很多的值,不存在的。这样子你只需要边缘OB一波就行啦。