視頻:JDBCRDD源碼及自定義JDBCRDD的分區策略

jdbcRDD雖然是雞肋,但是也值得一講。幫助大家更進一步理解RDD。 1,JDBCRDD使用 val data = new JdbcRDD(sc, getConnection , "SELECT id,aa FROM bbb where ? <= ID AND ID <= ?", lowerBound = 3, upperBound =5, numPartitions = 1, mapRow =
相關文章
相關標籤/搜索