我在JAVA中解析SparkSQL中的json文件,我需要能够访问在WrappedArrays的WrappedArray中返回的坐标.这是代码:
df.registerTempTable("test_articles"); sql = "select gnip.profileLocations.geo.coordinates FROM test_articles"; DataFrame testData = sqlContext.sql(sql); Row [] rowArray = testData.collect(); for(Row r:rowArray) { if(r.get(0)!=null) System.out.println(r.get(0).toString()); }
OUTPUT:WrappedArray(WrappedArray(30.74806,40.79944))
file.json
"gnip": { "profileLocations": [{ "objectType": "place", "geo": { "type": "point", "coordinates": [132.56111, 35.07693] } }] }
小智.. 6
Sparl SQL Row有一个getList
方法,它返回一个Java列表而不是WrappedArray.因此,在上面的例子中,可以说r.getList(0)
Sparl SQL Row有一个getList
方法,它返回一个Java列表而不是WrappedArray.因此,在上面的例子中,可以说r.getList(0)