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
}