@@ -835,7 +835,7 @@ package object geotiff {
835
835
836
836
val layout = rdd.metadata.layout
837
837
val crs = rdd.metadata.crs
838
- val geotiffResults = rdd.flatMap {
838
+ val groupedRDD = rdd.flatMap {
839
839
case (key, tile) => features.filter { case (_, extent) =>
840
840
val tileBounds = layout.mapTransform(extent)
841
841
@@ -844,7 +844,8 @@ package object geotiff {
844
844
((name, extent), (key, tile))
845
845
}
846
846
}.groupByKey()
847
- .map { case ((tileId, extent), tiles) =>
847
+ val geotiffResults = groupedRDD.map {
848
+ case ((tileId, extent), tiles) =>
848
849
// Each executor writes to a unique folder to avoid conflicts:
849
850
val executorAttemptDirectory = createExecutorAttemptDirectory(Path .of(path).getParent)
850
851
val filePath = executorAttemptDirectory + " /" + newFilePath(Path .of(path).getFileName.toString, tileId)
@@ -869,7 +870,7 @@ package object geotiff {
869
870
croppedExtent : Option [Extent ], cropDimensions : Option [java.util.ArrayList [Int ]],
870
871
compression : Compression , formatOptions : Option [GTiffOptions ] = None
871
872
): GeoTiffResultObject = {
872
- val raster : Raster [MultibandTile ] = ContextSeq (tiles, layout).sparseStitch() match {
873
+ val raster : Raster [MultibandTile ] = ContextSeq (tiles, layout).sparseStitch(geometry.extent ) match {
873
874
case Some (stitched) => stitched
874
875
case _ => {
875
876
logger.error(" stitchAndWriteToTiff(): sparseStitch returned None. Recovering by writing an empty raster." )
0 commit comments