update comment & parameters

vesoft-inc · Jan 15, 2021 · c4ab44e · c4ab44e
1 parent c620a79
commit c4ab44e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/example/src/main/scala/com/vesoft/nebula/examples/connector/NebulaSparkReaderExample.scala b/example/src/main/scala/com/vesoft/nebula/examples/connector/NebulaSparkReaderExample.scala
@@ -29,8 +29,8 @@ object NebulaSparkReaderExample {
       .config(sparkConf)
       .getOrCreate()
 
-    // readVertex(spark)
-    // readEdges(spark)
+    readVertex(spark)
+    readEdges(spark)
     readVertexGraph(spark)
     readEdgeGraph(spark)
 
@@ -91,7 +91,7 @@ object NebulaSparkReaderExample {
     val config =
       NebulaConnectionConfig
         .builder()
-        .withMetaAddress("192.168.8.172:45509")
+        .withMetaAddress("127.0.0.1:45500")
         .withTimeout(6000)
         .withConenctionRetry(2)
         .build()
@@ -115,7 +115,7 @@ object NebulaSparkReaderExample {
     val config =
       NebulaConnectionConfig
         .builder()
-        .withMetaAddress("192.168.8.172:45509")
+        .withMetaAddress("127.0.0.1:45500")
         .withTimeout(6000)
         .withConenctionRetry(2)
         .build()

diff --git a/nebula-spark-connector/src/main/scala/com/vesoft/nebula/connector/package.scala b/nebula-spark-connector/src/main/scala/com/vesoft/nebula/connector/package.scala
@@ -147,7 +147,7 @@ package object connector {
 
     /**
       * read nebula vertex edge to graphx's vertex
-      * only support Long vId
+      * use hash() for String type vertex id.
       */
     def loadVerticesToGraphx(): RDD[NebulaGraphxVertex] = {
       val vertexDataset = loadVerticesToDF()
@@ -179,7 +179,7 @@ package object connector {
 
     /**
       * read nebula edge edge to graphx's edge
-      * only support edge with Long srcId and Long dstId
+      * use hash() for String type srcId and dstId.
       */
     def loadEdgesToGraphx(): RDD[NebulaGraphxEdge] = {
       val edgeDataset = loadEdgesToDF()