Skip to content

Commit

Permalink
More visiblity clean-up
Browse files Browse the repository at this point in the history
  • Loading branch information
pwendell committed Mar 30, 2014
1 parent 42c1f09 commit 5a76ed6
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,11 +35,11 @@ import org.apache.spark.network._
import org.apache.spark.serializer.Serializer
import org.apache.spark.util._

sealed trait Values
private[spark] sealed trait Values

case class ByteBufferValues(buffer: ByteBuffer) extends Values
case class IteratorValues(iterator: Iterator[Any]) extends Values
case class ArrayBufferValues(buffer: ArrayBuffer[Any]) extends 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] class BlockManager(
executorId: String,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ import org.apache.spark.serializer.KryoSerializer
import org.apache.spark.util.Utils

/**
* Utility for micro-benchmarking shuffle write performance.
* Internal utility for micro-benchmarking shuffle write performance.
*
* Writes simulated shuffle output from several threads and records the observed throughput.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ private[spark] class Distribution(val data: Array[Double], val startIdx: Int, va
}
}

object Distribution {
private[spark] object Distribution {

def apply(data: Traversable[Double]): Option[Distribution] = {
if (data.size > 0) {
Expand Down

0 comments on commit 5a76ed6

Please sign in to comment.