视频: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 =
相关文章
相关标签/搜索