Fixed error in constructor

apache · Jul 1, 2015 · 1a8dba5 · 1a8dba5
1 parent 36db0dc
commit 1a8dba5
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 5 deletions.
diff --git a/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala b/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala
@@ -591,7 +591,7 @@ private[spark] abstract class ExternalSorter[K, V, C](
    *
    * This interface abstracts away aggregator dependence.
    */
-  override def writePartitionedFile(
+  def writePartitionedFile(
       blockId: BlockId,
       context: TaskContext,
       outputFile: File): Array[Long]

diff --git a/core/src/main/scala/org/apache/spark/util/collection/ExternalSorterAgg.scala b/core/src/main/scala/org/apache/spark/util/collection/ExternalSorterAgg.scala
@@ -86,7 +86,7 @@ private[spark] class ExternalSorterAgg[K, V, C](
     partitioner: Option[Partitioner] = None,
     ordering: Option[Ordering[K]] = None,
     serializer: Option[Serializer] = None)
-  extends ExternalSorter[K, V, C]
+  extends ExternalSorter[K, V, C](partitioner, ordering, serializer)
   with Spillable[WritablePartitionedPairCollection[K, C]]
   with SortShuffleFileWriter[K, V] {
 

diff --git a/core/src/main/scala/org/apache/spark/util/collection/ExternalSorterNoAgg.scala b/core/src/main/scala/org/apache/spark/util/collection/ExternalSorterNoAgg.scala
@@ -151,8 +151,7 @@ private[spark] class ExternalSorterNoAgg[K, V, C](
    */
   @VisibleForTesting
   override def partitionedIterator: Iterator[(Int, Iterator[Product2[K, C]])] = {
-    val collection: WritablePartitionedPairCollection[K, C] = buffer
-    partitionedIterator(collection)
+    partitionedIterator(buffer)
   }
 
   /**
@@ -167,7 +166,6 @@ private[spark] class ExternalSorterNoAgg[K, V, C](
       blockId: BlockId,
       context: TaskContext,
       outputFile: File): Array[Long] = {
-
     writePartitionedFile(blockId, context, outputFile, buffer)
   }
 }