使用scala将JavapairRDD转换为数据帧



我有一个格式为的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((

相关内容

  • 没有找到相关文章

最新更新