Advertisement
Guest User

Untitled

a guest
Jan 27th, 2020
116
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.29 KB | None | 0 0
  1.   val milanoGridDF = spark.read
  2.     .schema(geojsonSchema)
  3.     .json("data/Milano/milano-grid/milano-grid.geojson")
  4.     .select(explode(col("features")).as("lala"))
  5.     .select(col("lala").as[Features])
  6.     .map(f => (f.properties.cellId, f.geometry.coordinates))
  7.     .toDF("square_id", "coordinates")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement