From 8555251a723c8c00a2b9c3d7616f13276349a5cd Mon Sep 17 00:00:00 2001 From: Grisha Pomadchin Date: Thu, 31 Aug 2017 16:39:56 +0300 Subject: [PATCH] Improve S3 makePath function --- s3/src/main/scala/geotrellis/spark/io/s3/package.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/s3/src/main/scala/geotrellis/spark/io/s3/package.scala b/s3/src/main/scala/geotrellis/spark/io/s3/package.scala index 2e7d956c0a..f93e5ffd9d 100644 --- a/s3/src/main/scala/geotrellis/spark/io/s3/package.scala +++ b/s3/src/main/scala/geotrellis/spark/io/s3/package.scala @@ -21,7 +21,9 @@ import org.apache.spark.rdd.RDD package object s3 { private[s3] def makePath(chunks: String*) = - chunks.filter(_.nonEmpty).mkString("/") + chunks + .collect { case str if str.nonEmpty => if(str.endsWith("/")) str.dropRight(1) else str } + .mkString("/") implicit class withSaveToS3Methods[K](rdd: RDD[(K, Array[Byte])]) extends SaveToS3Methods(rdd) }