Skip to content

Commit da93886

Browse files
committed
Stringify still not working. FML.
1 parent 6a4e492 commit da93886

File tree

2 files changed

+4
-204
lines changed

2 files changed

+4
-204
lines changed

examples/src/main/scala/org/apache/spark/examples/graphx/PrePostProcessWiki.scala

Lines changed: 0 additions & 202 deletions
This file was deleted.

graphx/src/main/scala/org/apache/spark/graphx/GraphKryoRegistrator.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,7 @@ import org.apache.spark.serializer.KryoRegistrator
2525
import org.apache.spark.util.collection.BitSet
2626
import org.apache.spark.util.BoundedPriorityQueue
2727
import scala.collection.mutable
28-
import org.apache.hadoop.io.LongWritable
29-
import org.apache.hadoop.io.Text
28+
import org.apache.hadoop.io.{LongWritable, Text}
3029
// import org.apache.hadoop.conf.Configuration
3130
import org.apache.mahout.text.wikipedia._
3231

@@ -52,6 +51,9 @@ class GraphKryoRegistrator extends KryoRegistrator {
5251
kryo.register(classOf[LongWritable])
5352
kryo.register(classOf[Text])
5453
kryo.register(classOf[WikiArticle])
54+
// kryo.register(classOf[MakeString])
55+
// kryo.register(classOf[PrePostProcessWikipedia])
56+
// kryo.register(classOf[(LongWritable, Text)])
5557

5658
// This avoids a large number of hash table lookups.
5759
kryo.setReferences(false)

0 commit comments

Comments
 (0)