spark相关的算子（未完待续）

• • 转化算子
  • 执行算子

• map(func)

# java版本
RDD.map(new function>(){
	@overrid
	public Tuple2 call(String v1) throws Exception{
		return new Tuple2<>(v1,1)
	}
})

# scala版本
RDD.map(x=>(x,1))

• flatMap(func)

RDD.flatMap(new FlatMapFunction() {
    @Override
    public Iterable call(String s) throws Exception {
        return new ArrayList(Arrays.asList(s.split(" ")));
    }
  })

.flatMap(line => line.split(" "))

• reducebykey(func)

RDD.reduceByKey { case (x, y) => x + y }