java - 是否可以使用 java 通过 spark 连接任何 RDBMS？

Question

            JdbcRDD rdd = new org.apache.spark.rdd.JdbcRDD(
                    sparkConf,
                    ()= > {
                        Class.forName ("com.mysql.jdbc.Driver")
    sql.DriverManager.getConnection("jdbc:mysql://mysql.example.com/?user=batman&password=alfred")
  },
  "SELECT * FROM BOOKS WHERE ? <= KEY AND KEY <= ?",
  0, 1000, 10,
  row =  > row.getString("BOOK_TITLE")
         )

我尝试将上面的 scala 代码更改为 java 8，但是出现了很多错误。

Answer 1

我之前遇到过同样的问题，原来是sql参数的问题，基本上你需要像这样使用sql:sql
从书籍中选择 * 限制 ?, ?
lowerBound 和 upperBound 这两个参数是 JdbcRdd 构造函数所需要的。