Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val milanoGridDF = spark.read
- .schema(geojsonSchema)
- .json("data/Milano/milano-grid/milano-grid.geojson")
- .select(explode(col("features")).as("lala"))
- .select(col("lala").as[Features])
- .map(f => (f.properties.cellId, f.geometry.coordinates))
- .toDF("square_id", "coordinates")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement