From a837fa0696d1b1aed1de327f50bba8805dd3dd6d Mon Sep 17 00:00:00 2001 From: Grigory Pomadchin Date: Tue, 18 Dec 2018 17:34:41 +0300 Subject: [PATCH] Fixed cache method call as it could have an impact an all RDDs --- spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala | 2 +- .../main/scala/geotrellis/spark/ingest/MultibandIngest.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala b/spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala index b5b242d0da..adbe9c601f 100644 --- 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 index bd42812ba0..2ad2fac4ad 100644 --- 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)) =>