Spark中foreachRDD、foreachPartition和foreach解读

foreachRDD、foreachPartition和foreach的不一样之处主要在于它们的做用范围不一样,foreachRDD做用于DStream中每个时间间隔的RDD,foreachPartition做用于每个时间间隔的RDD中的每个partition,foreach做用于每个时间间隔的RDD中的每个元素。数据库   在Spark 官网中,foreachRDD被划分到Output Oper
相关文章
相关标签/搜索