aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/scala/org/apache/spark/util/CompletionIterator.scala
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/main/scala/org/apache/spark/util/CompletionIterator.scala')
-rw-r--r--core/src/main/scala/org/apache/spark/util/CompletionIterator.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/CompletionIterator.scala b/core/src/main/scala/org/apache/spark/util/CompletionIterator.scala
index 9044aaeef2..31d230d0fe 100644
--- a/core/src/main/scala/org/apache/spark/util/CompletionIterator.scala
+++ b/core/src/main/scala/org/apache/spark/util/CompletionIterator.scala
@@ -42,7 +42,7 @@ abstract class CompletionIterator[ +A, +I <: Iterator[A]](sub: I) extends Iterat
private[spark] object CompletionIterator {
def apply[A, I <: Iterator[A]](sub: I, completionFunction: => Unit) : CompletionIterator[A, I] = {
- new CompletionIterator[A,I](sub) {
+ new CompletionIterator[A, I](sub) {
def completion(): Unit = completionFunction
}
}