我有一个格式为的javapairRDD
org.apache.spark.api.java.JavaPairRDD[com.vividsolutions.jts.geom.Geometry,com.vividsolutions.jts.geom.Geometry]
关键点是多边形,值是多边形中的一个点
例如:
[(polygon(1,2,3,4), POINT (-80.0140735758427 40.43926684782609) )]
如何用三列将这个javapairRDD
转换为Dataframe
?
df: String, double, double
这里我的第一列是多边形,第二列是经度,第三列是纬度
如有任何帮助,将不胜感激
以下解决方案工作
javapairddvariable.rdd.toDF((