spark-connector 使用问题

最近在使用spark-connector来将HDFS上的数据导入到nebula,但是在使用spark-connector时遇到问题:图片中带框的部分指的是使用DF中对应的列名吗?

我在编写对应代码的时候,将DF的列名设置成了如下的格式:
image
该EDGE的创建语句为:
CREATE EDGE connect ( action string NULL, ts timestamp NULL, port string NULL, label string NULL ) ttl_duration = 0, ttl_col = “”
spark运行日志显示:


代码部分:

主要就是不知道DF中的列名和edge的schema通过哪里设置给它对应起来。

key not found: _vertexId

会不会是下划线的问题呢?:thinking: 你可以把 DF 改成 srcId 或者 vertexId 之类的么?


注释这些就好了。

1 个赞

如此神奇,@nicole 你看看呢?

:thinking: Nicole 给我截图了,原因是这个:

嗯 好的 我理解了 3Q

1 个赞

此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。