1

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();
    tableDat‌​aset.show();
    tableDat‌​aset.createOrReplace‌​TempView("TEMP_V");

    D‌​ataset<Row> tableDataset1 = spark.sql("SELECT NAME FROM TEMP_V");
    tableDataset1.show();
    tableDataset1.write().format("‌​org.apache.spark.ori‌​entdb.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' 

このエラーについて教えてください。読み取りと永続化に同じデータベース接続を使用しました

4

0 に答える 0