Geotrellis: чтение многофункционального шейп-файла в Spark RDD

У меня есть шейп-файл, содержащий несколько функций, и я хочу прочитать его в формате RDD. Пока у меня есть Seq[MultiPolygonFeature[Map[String,Object]]] с помощью ShapefileReader.readMultiPolygonFeatures,

Я хочу превратить его в нечто вроде RDD[(SpatialKey, Iterable[MultiPolygonFeature[UUID]])] или даже просто RDD[Feature[Polygon, UUID]] наберите и работайте оттуда. Я пытался найти примеры, но они, кажется, всегда начинаются с предварительно заполненного RDD полигонов.

def readShapefileToRDD(filepath: String): RDD[(SpatialKey, Iterable[MultiPolygonFeature[UUID]])] = {
  val features : Seq[MultiPolygonFeature[Map[String,Object]]] = ShapeFileReader.readMultiPolygonFeatures(filepath)

  val groupedPolys: RDD[(SpatialKey, Iterable[MultiPolygonFeature[UUID]])] = ???

  return groupedPolys
}

0 ответов

Другие вопросы по тегам