We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2c8adb2 commit d80c426Copy full SHA for d80c426
core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -335,11 +335,8 @@ private[spark] class BlockManager(
335
// initialization, etc.). Reducer read shuffle blocks one by one so we could do the
336
// wrapping lazily to save memory.
337
class LazyProxyIterator(f: => Iterator[Any]) extends Iterator[Any] {
338
-
339
lazy val proxy = f
340
341
override def hasNext: Boolean = proxy.hasNext
342
343
override def next(): Any = proxy.next()
344
}
345
0 commit comments