Add ranking config in exchange examples (#1408)

vesoft-inc · Jan 18, 2022 · affe0c3 · affe0c3
1 parent 22f38c8
commit affe0c3
Show file tree

Hide file tree

Showing 7 changed files with 46 additions and 0 deletions.
diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-clickhouse.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-clickhouse.md
@@ -239,6 +239,9 @@
         field:dst_player
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       # 单批次写入 Nebula Graph 的数据条数。
       batch: 256
 
@@ -266,6 +269,10 @@
       target: {
         field:teamid
       }
+
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       batch: 256
       partition: 32
     }

diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-hbase.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-hbase.md
@@ -264,6 +264,9 @@ ROW                                COLUMN+CELL
           field:dst_player
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       # 单批次写入 Nebula Graph 的数据条数。
       batch: 256
 
@@ -293,6 +296,9 @@ ROW                                COLUMN+CELL
           field:teamid
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       batch: 256
       partition: 32
     }

diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-hive.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-hive.md
@@ -296,6 +296,9 @@ scala> sql("select playerid, teamid, start_year, end_year from basketball.serve"
         field: dst_player
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       # 单批次写入 Nebula Graph 的最大数据条数。
       batch: 256
 
@@ -319,6 +322,10 @@ scala> sql("select playerid, teamid, start_year, end_year from basketball.serve"
       target: {
         field: teamid
       }
+
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       batch: 256
       partition: 32
     }

diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-kafka.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-kafka.md
@@ -223,6 +223,9 @@
           field:offset
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       # 单批次写入 Nebula Graph 的数据条数。
       batch: 10
 
@@ -253,6 +256,9 @@
           field:value
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       batch: 10
       partition: 10
       interval.seconds: 10

diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-maxcompute.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-maxcompute.md
@@ -264,6 +264,9 @@
         field: dst_player
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       # Spark 分区数量
       partition:10
 
@@ -294,6 +297,10 @@
       target:{
         field: teamid
       }
+
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       partition:10
       batch:10
     }

diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-mysql.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-mysql.md
@@ -277,6 +277,9 @@ mysql> desc serve;
         field: dst_player
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       # 单批次写入 Nebula Graph 的数据条数。
       batch: 256
 
@@ -307,6 +310,10 @@ mysql> desc serve;
       target: {
         field: teamid
       }
+
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       batch: 256
       partition: 32
     }

diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-pulsar.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-pulsar.md
@@ -229,6 +229,9 @@
           field:dst_player
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       # 单批次写入 Nebula Graph 的数据条数。
       batch: 10
 
@@ -262,6 +265,9 @@
           field:teamid
       }
 
+      # 指定一个列作为 rank 的源（可选）。
+      #ranking: rank
+
       batch: 10
       partition: 10
       interval.seconds: 10