ошибка при использовании спарк-края записи в orientDB - PullRequest
0 голосов
/ 13 февраля 2019

использовать spark api, сначала записать вершину в orientDB, а затем записать ребро.сообщение об ошибке «com.orientechnologies.orient.core.exception.OCommandExecutionException: класс Egraphx уже существует».// использовать режим кластер-клиент spark orientDB версия: 3.0.13 версия spark: 2.2.1 org.apache.spark spark-orientdb-2.2.1_2.11 1.4

df_vex
.write
.format("org.apache.spark.orientdb.graphs")
.option("dburl", "remote:10.145.77.105:8424/addressList")
.option("user", "admin")
.option("password", "admin")
.option("vertextype", "Vgraphx")
.mode(SaveMode.Overwrite)
.save()
//
df_addressSelect
.select("phone", "num", "name")
.toDF("src", "dst", "name")
.write
.format("org.apache.spark.orientdb.graphs")
.option("dburl", "remote:10.145.77.105:8424/addressList")
.option("user", "admin")
.option("password", "admin")
.option("vertextype", "Vgraphx")
.option("edgetype", "Egraphx")
.mode(SaveMode.Overwrite)
.save()
...