Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
lianhuiwang committed Jul 1, 2015
1 parent f4737bb commit 907366b
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,7 @@ private[spark] class ExternalSorter[K, V, C](
// Information about a spilled file. Includes sizes in bytes of "batches" written by the
// serializer as we periodically reset its stream, as well as number of elements in each
// partition, used to efficiently keep track of partitions when merging.
private[this] case class SpilledFile(
private[spark] case class SpilledFile(
file: File,
blockId: BlockId,
serializerBatchSizes: Array[Long],
Expand Down Expand Up @@ -667,7 +667,7 @@ private[spark] class ExternalSorter[K, V, C](
}
}

def cleanup(): Unit = {
private[spark] def cleanup(): Unit = {
spillFile.foreach(_.file.delete())
}
}
Expand Down

0 comments on commit 907366b

Please sign in to comment.