diff --git a/docs-2.0/nebula-exchange/parameter-reference/ex-ug-parameter.md b/docs-2.0/nebula-exchange/parameter-reference/ex-ug-parameter.md index eadc5f624cc..2d0e9efa54a 100644 --- a/docs-2.0/nebula-exchange/parameter-reference/ex-ug-parameter.md +++ b/docs-2.0/nebula-exchange/parameter-reference/ex-ug-parameter.md @@ -102,6 +102,9 @@ |`tags.fields`|list\[string\]|-|是|属性对应的列的表头或列名。如果有表头或列名，请直接使用该名称。如果 CSV 文件没有表头，用`[_c0, _c1, _c2]`的形式表示第一列、第二列、第三列，以此类推。| |`tags.nebula.fields`|list\[string\]|-|是|{{nebula.name}}中定义的属性名称，顺序必须和`tags.fields`一一对应。例如`[_c1, _c2]`对应`[name, age]`，表示第二列为属性 name 的值，第三列为属性 age 的值。| |`tags.vertex.field`|string|-|是|点 ID 的列。例如 CSV 文件没有表头时，可以用`_c0`表示第一列的值作为点 ID。| +|`tags.vertex.udf.separator`|string|-|否|通过自定义规则合并多列，该参数指定连接符。| +|`tags.vertex.udf.oldColNames`|list|-|否|通过自定义规则合并多列，该参数指定待合并的列名。多个列用英文逗号（,）分隔。| +|`tags.vertex.udf.newColName`|string|-|否|通过自定义规则合并多列，该参数指定新列的列名。| |`tags.batch`|int|`256`|是|单批次写入{{nebula.name}}的最大点数量。| |`tags.partition`|int|`32`|是|Spark 分片数量。| diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-export-from-nebula.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-export-from-nebula.md index 75f688888f9..7a578182147 100644 --- a/docs-2.0/nebula-exchange/use-exchange/ex-ug-export-from-nebula.md +++ b/docs-2.0/nebula-exchange/use-exchange/ex-ug-export-from-nebula.md @@ -229,6 +229,11 @@ CentOS 7.9.2009 nebula.fields: [target_nebula-field-0, target_nebula-field-1, target_nebula-field-2] limit:10000 vertex: _vertexId # must be `_vertexId` + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } batch: 2000 partition: 60 } @@ -250,7 +255,17 @@ CentOS 7.9.2009 nebula.fields: [target_nebula-field-0, target_nebula-field-1, target_nebula-field-2] limit:1000 source: _srcId # must be `_srcId` + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } target: _dstId # must be `_dstId` + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } ranking: source_nebula-field-2 batch: 2000 partition: 60 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 feb7a1e3274..39db1db6b3b 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 @@ -168,6 +168,11 @@ # 指定表中某一列数据为{{nebula.name}}中点 VID 的来源。 vertex: { field:playerid + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } # policy:hash } @@ -238,11 +243,21 @@ # 在 source 里，将 follow 表中某一列作为边的起始点数据源。 source: { field:src_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 在 target 里，将 follow 表中某一列作为边的目的点数据源。 target: { field:dst_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-csv.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-csv.md index 444d134c14c..79b6382c771 100644 --- a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-csv.md +++ b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-csv.md @@ -187,6 +187,11 @@ # 目前，{{nebula.name}} {{nebula.release}}仅支持字符串或整数类型的 VID。 vertex: { field:_c0 + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } # policy:hash } @@ -285,9 +290,19 @@ # 目前，{{nebula.name}} {{nebula.release}}仅支持字符串或整数类型的 VID。 source: { field: _c0 + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: _c1 + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定的分隔符。默认值为英文逗号（,）。 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 faf08d1b10a..7c742d694ea 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 @@ -199,6 +199,11 @@ ROW COLUMN+CELL # 例如 rowkey 作为 VID 的来源，请填写“rowkey”。 vertex:{ field:rowkey + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 单批次写入 {{nebula.name}} 的数据条数。 @@ -260,10 +265,20 @@ ROW COLUMN+CELL # 在 target 里，将 follow 表中某一列作为边的目的点数据源。示例使用列 dst_player。 source:{ field:rowkey + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target:{ field:dst_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 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 56d0f75175d..a3bc3cabf1f 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 @@ -236,6 +236,11 @@ scala> sql("select playerid, teamid, start_year, end_year from basketball.serve" # 指定表中某一列数据为 {{nebula.name}} 中点 VID 的来源。 vertex:{ field:playerid + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 单批次写入 {{nebula.name}} 的最大数据条数。 @@ -292,10 +297,20 @@ scala> sql("select playerid, teamid, start_year, end_year from basketball.serve" # 在 target 里，将 follow 表中某一列作为边的目的点数据源。 source: { field: src_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: dst_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-jdbc.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-jdbc.md index 34a600df49b..74b487a19da 100644 --- a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-jdbc.md +++ b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-jdbc.md @@ -226,6 +226,11 @@ mysql> desc serve; # 指定表中某一列数据为 {{nebula.name}} 中点 VID 的来源。 vertex: { field:playerid + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 单批次写入 {{nebula.name}} 的数据条数。 @@ -304,10 +309,20 @@ mysql> desc serve; # 在 target 里，将 follow 表中某一列作为边的目的点数据源。 source: { field: src_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: dst_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 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 c7d3d60b5d1..cad2dc729eb 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 @@ -215,6 +215,11 @@ # 目前，{{nebula.name}} {{nebula.release}}仅支持字符串或整数类型的 VID。 vertex: { field:id + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定单批次写入 {{nebula.name}} 的最大点数量。 @@ -297,9 +302,19 @@ # 目前，{{nebula.name}} {{nebula.release}}仅支持字符串或整数类型的 VID。 source: { field: src + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: dst + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 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 0b3a6329320..3c71d2a413d 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 @@ -152,6 +152,11 @@ # 这里的值 key 和上面的 key 重复，表示 key 既作为 VID，也作为属性 name。 vertex:{ field:personId + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 单批次写入 {{nebula.name}} 的数据条数。 @@ -213,10 +218,20 @@ # 在 target 里，将 topic 中某一列作为边的目的点数据源。 source:{ field:srcPersonId + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target:{ field:dstPersonId + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 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 2aa193eb5b1..a8631ac68c5 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 @@ -179,6 +179,11 @@ # 指定表中某一列数据为 {{nebula.name}} 中点 VID 的来源。 vertex:{ field: playerid + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 单批次写入 {{nebula.name}} 的数据条数。 @@ -259,11 +264,21 @@ # 在 source 里，将 follow 表中某一列作为边的起始点数据源。 source:{ field: src_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 在 target 里，将 follow 表中某一列作为边的目的点数据源。 target:{ field: dst_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 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 a2ba14ccb06..a74647b65f1 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 @@ -204,6 +204,11 @@ mysql> desc serve; # 指定表中某一列数据为 {{nebula.name}} 中点 VID 的来源。 vertex: { field:playerid + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 单批次写入 {{nebula.name}} 的数据条数。 @@ -273,10 +278,20 @@ mysql> desc serve; # 在 target 里，将 follow 表中某一列作为边的目的点数据源。 source: { field: src_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: dst_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-neo4j.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-neo4j.md index 99b204281e1..0337cc83a04 100644 --- a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-neo4j.md +++ b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-neo4j.md @@ -182,6 +182,11 @@ Exchange 读取 Neo4j 数据时需要完成以下工作： nebula.fields: [age,name] vertex: { field:id + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } partition: 10 batch: 1000 @@ -229,9 +234,19 @@ Exchange 读取 Neo4j 数据时需要完成以下工作： nebula.fields: [degree] source: { field: src + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: dst + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } #ranking: rank partition: 10 diff --git a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-oracle.md b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-oracle.md index a5394b13193..e78012b0062 100644 --- a/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-oracle.md +++ b/docs-2.0/nebula-exchange/use-exchange/ex-ug-import-from-oracle.md @@ -205,6 +205,11 @@ oracle> desc serve; # 指定表中某一列数据为{{nebula.name}}中点 VID 的来源。 vertex: { field:playerid + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 单批次写入{{nebula.name}}的数据条数。 @@ -272,10 +277,20 @@ oracle> desc serve; # 在 target 里，将 follow 表中某一列作为边的目的点数据源。 source: { field: src_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: dst_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 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 963062378fc..a4d3e44aa60 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 @@ -183,6 +183,11 @@ # 目前，{{nebula.name}} {{nebula.release}}仅支持字符串或整数类型的 VID。 vertex: { field:id + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定单批次写入{{nebula.name}}的最大点数量。 @@ -265,9 +270,19 @@ # 目前，{{nebula.name}} {{nebula.release}}仅支持字符串或整数类型的 VID。 source: { field: src + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: dst + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 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 9c92218c65a..fccdf4f89a4 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 @@ -183,6 +183,11 @@ # 目前，{{nebula.name}} {{nebula.release}}仅支持字符串或整数类型的 VID。 vertex: { field:id + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定单批次写入{{nebula.name}}的最大点数量。 @@ -265,9 +270,19 @@ # 目前，{{nebula.name}} {{nebula.release}}仅支持字符串或整数类型的 VID。 source: { field: src + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target: { field: dst + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。 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 3bd8a18329a..3aec5fbf520 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 @@ -156,6 +156,11 @@ # 指定表中某一列数据为{{nebula.name}}中点 VID 的来源。 vertex:{ field:playerid + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 单批次写入{{nebula.name}}的数据条数。 @@ -225,10 +230,20 @@ # 在 target 里，将 follow 表中某一列作为边的目的点数据源。 source:{ field:src_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } target:{ field:dst_player + # udf:{ + # separator:"_" + # oldColNames:[field-0,field-1,field-2] + # newColName:new-field + # } } # 指定一个列作为 rank 的源（可选）。