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