0

我有以下格式的 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) )]

如何将其转换javapairRDDDataframe三列?

df: String, double, double

这里我的第一列是一个多边形,第二列是经度,第三列是纬度

任何帮助将不胜感激

4

1 回答 1

0

以下解决方案有效

javapairrddvariable.rdd.toDF()

于 2020-02-26T02:30:05.820 回答