Stringify still not working. FML.

ankurdave · Feb 23, 2014 · da93886 · da93886
1 parent 6a4e492
commit da93886
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 204 deletions.
diff --git a/examples/src/main/scala/org/apache/spark/examples/graphx/PrePostProcessWiki.scala b/examples/src/main/scala/org/apache/spark/examples/graphx/PrePostProcessWiki.scala
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/GraphKryoRegistrator.scala b/graphx/src/main/scala/org/apache/spark/graphx/GraphKryoRegistrator.scala
@@ -25,8 +25,7 @@ import org.apache.spark.serializer.KryoRegistrator
 import org.apache.spark.util.collection.BitSet
 import org.apache.spark.util.BoundedPriorityQueue
 import scala.collection.mutable
-import org.apache.hadoop.io.LongWritable
-import org.apache.hadoop.io.Text
+import org.apache.hadoop.io.{LongWritable, Text}
 // import org.apache.hadoop.conf.Configuration
 import org.apache.mahout.text.wikipedia._
 
@@ -52,6 +51,9 @@ class GraphKryoRegistrator extends KryoRegistrator {
     kryo.register(classOf[LongWritable])
     kryo.register(classOf[Text])
     kryo.register(classOf[WikiArticle])
+//     kryo.register(classOf[MakeString])
+//     kryo.register(classOf[PrePostProcessWikipedia])
+//     kryo.register(classOf[(LongWritable, Text)])
 
     // This avoids a large number of hash table lookups.
     kryo.setReferences(false)