javaを使用してSparkデータセットをOrientDBに書き込むにはどうすればよいですか?
Orient Java JDBC ドライバーを使用して OrientDB からデータを既に読み取っていますが、同じデータセットを OrientDB に永続化することができません。
コード:
public void readAndWriteData(SparkSession spark, Map<String, String> dbProps, Properties destinationDb) {
Dataset<Row> tableDataset = spark.read().format("jdbc").options(dbProps).load();
tableDataset.show();
tableDataset.createOrReplaceTempView("TEMP_V");
Dataset<Row> tableDataset1 = spark.sql("SELECT NAME FROM TEMP_V");
tableDataset1.show();
tableDataset1.write().format("org.apache.spark.orientdb.documents")
.option("dburl", "jdbc:orient:REMOTE:localhost/testdb")
.option("user", "root")
.option("password", "root")
.option("class", "Test")
.mode(SaveMode.Append).save();
}
ここで私はエラーが発生しています
Exception in thread "main" java.lang.RuntimeException: Connection Exception Occurred: Error on opening database 'jdbc:orient:REMOTE:localhost/testdb'
このエラーについて教えてください。読み取りと永続化に同じデータベース接続を使用しました