是否可以通过spark usinig java连接任何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： JdbcRdd构造函数需要的sql select * from books limit ?, ? 两个参数lowerBound和。upperBound