File tree Expand file tree Collapse file tree 2 files changed +4
-204
lines changed
examples/src/main/scala/org/apache/spark/examples/graphx
graphx/src/main/scala/org/apache/spark/graphx Expand file tree Collapse file tree 2 files changed +4
-204
lines changed Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -25,8 +25,7 @@ import org.apache.spark.serializer.KryoRegistrator
2525import org .apache .spark .util .collection .BitSet
2626import org .apache .spark .util .BoundedPriorityQueue
2727import 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
3130import 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 )
You can’t perform that action at this time.
0 commit comments