преобразовать JavapairRDD в фрейм данных, используя scala - PullRequest
0 голосов
/ 25 февраля 2020

У меня есть 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

Здесь мой первый столбец будет многоугольником, второй столбец - долготой, а третий столбец - широтой

Любая помощь будет оценена

1 Ответ

0 голосов
/ 26 февраля 2020

ниже решение работает

javapairrddvariable.rdd.toDF ()

...