tested

apache · Feb 11, 2015 · cbc720f · cbc720f
1 parent 686af40
commit cbc720f
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/loaders/RDFLoader.scala b/graphx/src/main/scala/org/apache/spark/graphx/loaders/RDFLoader.scala
@@ -54,9 +54,10 @@ object RDFLoader extends Logging {
   def loadNTriples(
       sc: SparkContext,
       path: String,
-      // numPartitions: Int = -1,
+      //numPartitions: Int = -1,
       edgeStorageLevel: StorageLevel = StorageLevel.MEMORY_ONLY,
-      vertexStorageLevel: StorageLevel = StorageLevel.MEMORY_ONLY)
+      vertexStorageLevel: StorageLevel = StorageLevel.MEMORY_ONLY
+      )
     : Graph[String, String] =
   {
     val startTime = System.currentTimeMillis()
@@ -72,7 +73,7 @@ object RDFLoader extends Logging {
       }
     })
     .distinct()
-    // .repartition(numPartitions)
+    //.repartition(numPartitions)
     .map(name => 
       name match {
         case propvalregex(pre, value) => (gethash("<" + pre + "> " + value), value)
@@ -108,3 +109,4 @@ object RDFLoader extends Logging {
   }
 
 }
+