提问参考模版:
- nebula 版本:2.5.1
- 部署方式(分布式 / 单机 / Docker / DBaaS):单机
- 是否为线上版本:N
示例代码使用的是scala语言
spark.read.nebula(config, nebulaReadEdgeConfig).loadEdgesToGraphx()
参考上述示例的java代码
sparkSession.read().nebula(connectionConfig, readGraphoneConfig).loadEdgesToGraphx();
编译失败,因为sparkSession.read()的返回对象是DataFrameReader,没有nebula方法。而在scala示例代码中可以返回NebulaDataFrameReader。
使用spark-connector读取grapsh数据的java代码该怎么实现?