最近在使用spark-connector来将HDFS上的数据导入到nebula,但是在使用spark-connector时遇到问题:图片中带框的部分指的是使用DF中对应的列名吗?
我在编写对应代码的时候,将DF的列名设置成了如下的格式:

该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通过哪里设置给它对应起来。




