使用Java代码如何通过nebula-spark-connector从Nebula Graph读取数据

提问参考模版:

  • 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代码该怎么实现?

1 个赞

java 中调用scala api这样写:
package$.MODULE$.NebulaDataFrameReader(spark.read()).nebula(config, nebulaReadVertexConfig).loadVerticesToDF();

1 个赞

import com.vesoft.nebula.connector.connector.package$;

1 个赞

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