Merge pull request #2854 from pomadchin/fix/ingest-object

Fixe cache level in Ingest objects
locationtech · Dec 18, 2018 · 67ea7b2 · 67ea7b2
2 parents 11c2609 + a837fa0
commit 67ea7b2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala b/spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala
@@ -77,7 +77,7 @@ object Ingest {
       case _ => sourceTiles.collectMetadata(FloatingLayoutScheme(256))
     }
 
-    val contextRdd = sourceTiles.tileToLayout(tileLayerMetadata, resampleMethod).cache()
+    val contextRdd = sourceTiles.tileToLayout(tileLayerMetadata, resampleMethod).persist(cacheLevel)
 
     val (zoom, tileLayerRdd) = (layoutScheme, maxZoom) match {
       case (layoutScheme: ZoomedLayoutScheme, Some(mz)) =>

diff --git a/spark/src/main/scala/geotrellis/spark/ingest/MultibandIngest.scala b/spark/src/main/scala/geotrellis/spark/ingest/MultibandIngest.scala
@@ -51,7 +51,7 @@ object MultibandIngest {
       case _ => sourceTiles.collectMetadata(FloatingLayoutScheme(256))
     }
 
-    val contextRdd = sourceTiles.tileToLayout(tileLayerMetadata, resampleMethod).cache()
+    val contextRdd = sourceTiles.tileToLayout(tileLayerMetadata, resampleMethod).persist(cacheLevel)
 
     val (zoom, tileLayerRdd) = (layoutScheme, maxZoom) match {
       case (layoutScheme: ZoomedLayoutScheme, Some(mz)) =>