累加器只能在Driver定义初始化，不能在Executor端定义初始化。 accumulator相当...

阅读(3)评论(4)2020-03-18

赞(0)

窄依赖： 父RDD与子RDD partion之间的关系是一对一、多对一。 宽依赖（有shuffle)...

阅读(3)评论(8)2020-03-16

赞(1)

transformations算子 mapPartitionWithIndex 类似于mapPart...

阅读(3)评论(8)2020-03-14

赞(0)

基于Standalne的两种提交模式 1、Standalne-client模式提交任务 ./spar...

阅读(3)评论(4)2020-03-13

赞(1)

package wordcount import org.apache.spark.SparkCon...

阅读(3)评论(8)2020-03-13

赞(0)

package spark; import java.util.Arrays; import org...

阅读(4)评论(5)2020-03-12

赞(0)