Permalink
Browse files

Use fakeClassTag

  • Loading branch information...
1 parent 0d624bf commit 4421ecc35a235aee8fa24797be9c10b9bd43163a @holdenk committed Feb 27, 2014
@@ -19,10 +19,12 @@ package org.apache.spark.api.java.function
import scala.reflect.ClassTag
+import org.apache.spark.api.java.JavaSparkContext.fakeClassTag
+
/**
* A function that takes the a partition
*/
abstract class MapPartitionsWithIndexFunction[A, B] extends Function2[Integer,
java.util.Iterator[A], java.util.Iterator[B]] {
- def elementType() : ClassTag[B] = ClassTag.Any.asInstanceOf[ClassTag[B]]
+ def elementType() : ClassTag[B] = fakeClassTag
}

0 comments on commit 4421ecc

Please sign in to comment.