From 542a736ad992301197a0ecd484c8cf258f46a32a Mon Sep 17 00:00:00 2001 From: Patrick Wendell Date: Sun, 30 Mar 2014 17:25:25 -0700 Subject: [PATCH] Small fixes --- core/src/main/scala/org/apache/spark/SparkEnv.scala | 2 +- .../main/scala/org/apache/spark/storage/BlockManager.scala | 4 ++-- .../scala/org/apache/spark/util/random/RandomSampler.scala | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/SparkEnv.scala b/core/src/main/scala/org/apache/spark/SparkEnv.scala index 36748766f377a..0e2965e714dd7 100644 --- a/core/src/main/scala/org/apache/spark/SparkEnv.scala +++ b/core/src/main/scala/org/apache/spark/SparkEnv.scala @@ -41,7 +41,7 @@ import org.apache.spark.util.{AkkaUtils, Utils} * objects needs to have the right SparkEnv set. You can get the current environment with * SparkEnv.get (e.g. after creating a SparkContext) and set it with SparkEnv.set. */ -private[spark] class SparkEnv private[spark] ( +private[spark] class SparkEnv ( val executorId: String, val actorSystem: ActorSystem, val serializer: Serializer, diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala index ca8ca650528b7..f7ac1bddd3b8f 100644 --- a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala +++ b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala @@ -38,8 +38,8 @@ import org.apache.spark.util._ private[spark] sealed trait Values private[spark] case class ByteBufferValues(buffer: ByteBuffer) extends Values -private[spark]case class IteratorValues(iterator: Iterator[Any]) extends Values -private[spark]case class ArrayBufferValues(buffer: ArrayBuffer[Any]) extends Values +private[spark] case class IteratorValues(iterator: Iterator[Any]) extends Values +private[spark] case class ArrayBufferValues(buffer: ArrayBuffer[Any]) extends Values private[spark] class BlockManager( executorId: String, diff --git a/core/src/main/scala/org/apache/spark/util/random/RandomSampler.scala b/core/src/main/scala/org/apache/spark/util/random/RandomSampler.scala index dfa6013c58083..1fb2f60a8cd9d 100644 --- a/core/src/main/scala/org/apache/spark/util/random/RandomSampler.scala +++ b/core/src/main/scala/org/apache/spark/util/random/RandomSampler.scala @@ -70,7 +70,7 @@ class BernoulliSampler[T](lb: Double, ub: Double, complement: Boolean = false) override def clone = new BernoulliSampler[T](lb, ub) } -/** Ps +/** * DEVELOPER API - UNSTABLE * * A sampler based on values drawn from Poisson distribution.