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 index e004262850c..71f03ff18e0 100644 --- 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 index 40c8cdb3e45..116bd36989e 100644 --- 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 index 7ebe29a04bf..63603b020e8 100644 --- 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 index aefbbb6f850..bf02658f023 100644 --- 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 index c16c1cef83e..bb9c23ce1f0 100644 --- 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 index 39f33bd0b67..a1f031b04cc 100644 --- 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 index aa7e01ea372..a9de2e3fb74 100644 --- 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