通過SparkAPI方式讀取Mysql數據庫數據創建RDD,sql查詢語句執行情況

一、創建的測試用表rdd.student(id int,name string) 二、在代碼中創建JdbcRDD讀取數據 三、我們可以看到sql="select * from student where id > ? and id < ? " 其中?是佔位符,第一個?是lowerBound ,第二個?是UpperBound 由於我們這裏numPartitions設置=2,所以最後查詢的語句翻譯成s
相關文章
相關標籤/搜索