Skip to content

Commit 532c564

Browse files
committed
Added back commented-out method, as per Matei's request
1 parent 904655e commit 532c564

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

core/src/main/scala/org/apache/spark/shuffle/ShuffleReader.scala

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,4 +23,11 @@ package org.apache.spark.shuffle
2323
private[spark] trait ShuffleReader[K, C] {
2424
/** Read the combined key-values for this reduce task */
2525
def read(): Iterator[Product2[K, C]]
26+
27+
/**
28+
* Close this reader.
29+
* TODO: Add this back when we make the ShuffleReader a developer API that others can implement
30+
* (at which point this will likely be necessary).
31+
*/
32+
// def stop(): Unit
2633
}

0 commit comments

Comments
 (0)