J'ai un javapairRDD au format ci-dessous

org.apache.spark.api.java.JavaPairRDD[com.vividsolutions.jts.geom.Geometry,com.vividsolutions.jts.geom.Geometry]

La clé est un polygone et la valeur est un point dans le polygone

Par exemple:

[(polygon(1,2,3,4), POINT (-80.0140735758427 40.43926684782609) )]

Comment transformer ce javapairRDD en Dataframe avec trois colonnes ?

df: String, double, double

Ici ma première colonne sera un polygone, la deuxième colonne en longitude et la troisième colonne en latitude

Toute aide serait appréciée

0
user2981952 25 févr. 2020 à 01:26

1 réponse

Meilleure réponse

La solution ci-dessous a fonctionné

Javapairrddvariable.rdd.toDF()

0
user2981952 26 févr. 2020 à 02:30