From c719b3ee08286c12043958dbafffe72a0bab2901 Mon Sep 17 00:00:00 2001 From: randomJoe211 <69501902+randomJoe211@users.noreply.github.com> Date: Tue, 18 Jan 2022 15:16:23 +0800 Subject: [PATCH] Add ranking config in exchange examples --- .../use-exchange/ex-ug-import-from-clickhouse.md | 7 +++++++ .../use-exchange/ex-ug-import-from-hbase.md | 5 +++++ .../nebula-exchange/use-exchange/ex-ug-import-from-hive.md | 7 +++++++ .../nebula-exchange/use-exchange/ex-ug-import-from-json.md | 6 ++---- .../use-exchange/ex-ug-import-from-kafka.md | 5 +++++ .../use-exchange/ex-ug-import-from-maxcompute.md | 7 +++++++ .../use-exchange/ex-ug-import-from-mysql.md | 3 +++ .../nebula-exchange/use-exchange/ex-ug-import-from-orc.md | 2 -- .../use-exchange/ex-ug-import-from-parquet.md | 3 --- .../use-exchange/ex-ug-import-from-pulsar.md | 6 +++++- 10 files changed, 41 insertions(+), 10 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 index 53135a64c18..3cf2d0e0d0f 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 @@ -238,6 +238,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field:dst_player } + # (Optional) Specify a column as the source of the rank. + #ranking: rank + # The number of data written to Nebula Graph in a single batch. batch: 256 @@ -265,6 +268,10 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` target: { field:teamid } + + # (Optional) Specify a column as the source of the 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 a7d208c0ae1..2eecd7b36f8 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 @@ -267,6 +267,8 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field:dst_player } + # (Optional) Specify a column as the source of the rank. + #ranking: rank # The number of data written to Nebula Graph in a single batch. batch: 256 @@ -297,6 +299,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field:teamid } + # (Optional) Specify a column as the source of the 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 c3ef7e03f9f..3c8d994aefa 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 @@ -298,6 +298,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field: dst_player } + # (Optional) Specify a column as the source of the rank. + #ranking: rank + # The number of data written to Nebula Graph in a single batch. batch: 256 @@ -321,6 +324,10 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` target: { field: teamid } + + # (Optional) Specify a column as the source of the rank. + #ranking: rank + batch: 256 partition: 32 } diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-json.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-json.md index 93b02850b6f..b4f9a52a31f 100644 --- a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-json.md +++ b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-json.md @@ -303,7 +303,7 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` } - # (optionally) Specify a column as the source of the rank. + # (Optional) Specify a column as the source of the rank. #ranking: rank # The number of data written to Nebula Graph in a single batch. @@ -348,11 +348,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field: dst } - - # (optionally) Specify a column as the source of the rank. + # (Optional) Specify a column as the source of the rank. #ranking: _c5 - # The number of data written to Nebula Graph in a single batch. batch: 256 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 49723585c57..558aceadc97 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 @@ -227,6 +227,8 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field:offset } + # (Optional) Specify a column as the source of the rank. + #ranking: rank # The number of data written to Nebula Graph in a single batch. batch: 10 @@ -258,6 +260,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field:value } + # (Optional) Specify a column as the source of the 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 ae5e2438476..87b451d965b 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 @@ -261,6 +261,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field: dst_player } + # (Optional) Specify a column as the source of the rank. + #ranking: rank + # The number of Spark partitions. partition:10 @@ -291,6 +294,10 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` target:{ field: teamid } + + # (Optional) Specify a column as the source of the 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 9591f02498e..ca69d4c6d4c 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 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field: dst_player } + # (Optional) Specify a column as the source of the rank. + #ranking: rank + # The number of data written to Nebula Graph in a single batch. batch: 256 diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-orc.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-orc.md index fb33d97ddd6..14647665f42 100644 --- a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-orc.md +++ b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-orc.md @@ -270,7 +270,6 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field: dst } - # (Optional) Specify a column as the source of the rank. #ranking: rank @@ -319,7 +318,6 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` # (Optional) Specify a column as the source of the rank. #ranking: _c5 - # The number of data written to Nebula Graph in a single batch. batch: 256 diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-parquet.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-parquet.md index 080800b259a..ac5f0dd928c 100644 --- a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-parquet.md +++ b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-parquet.md @@ -270,7 +270,6 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field: dst } - # (Optional) Specify a column as the source of the rank. #ranking: rank @@ -316,11 +315,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field: dst } - # (Optional) Specify a column as the source of the rank. #ranking: _c5 - # The number of data written to Nebula Graph in a single batch. batch: 256 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 b387f7a14f1..987e0042317 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,11 +229,12 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field:src_player } - target:{ field:dst_player } + # (Optional) Specify a column as the source of the rank. + #ranking: rank # The number of data written to Nebula Graph in a single batch. batch: 10 @@ -268,6 +269,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf` field:teamid } + # (Optional) Specify a column as the source of the rank. + #ranking: rank + batch: 10 partition: 10 interval.seconds: 10