Skip to content

Commit

Permalink
Update ex-ug-import-from-kafka.md
Browse files Browse the repository at this point in the history
  • Loading branch information
randomJoe211 committed Dec 22, 2021
1 parent b9984d4 commit ac48d6d
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,7 @@
# Kafka 数据有固定的域名称:key、value、topic、partition、offset、timestamp、timestampType。
# 在 fields 里指定 Kafka value 中的字段名称,多个字段用英文逗号(,)隔开。Spark Structured Streaming 读取 Kafka 数据后会将其以 JSON 格式存储于 value 字段中,而这里的 fields 要配置 JSON 的 key 名。示例如下:
fields: [personName, age]
# 设置 fields 中的 key 保存到 Nebula Graph 时转换成的属性名。下方设置会将 name 保存为 Nebula Graph 中的 personName 属性,age 则保存为同名属性。
# 设置 fields 中的 key 保存到 Nebula Graph 时转换成的属性名。下方设置会将 personName 保存为 Nebula Graph 中的 name 属性,age 则保存为同名属性。
nebula.fields: [name, age]
# 指定表中某一列数据为 Nebula Graph 中点 VID 的来源。
Expand Down

0 comments on commit ac48d6d

Please sign in to comment.