Package
Package需要把global rearrange处理后的key, Seq
tuple.get(0)是keyTuple，tuple.get(1)是Iterator
Spork: Pig on Spark实现分析(二)
ap操作先将Tuple从(index, key, value)转成(key, value)形态，然后把这个rdd集合new成CoGroupRDD，包含一次(Seq) JavaConversions.asScalaBuffer(rddPairs)转化。最后调用CoGroupRDD的map方法，把Tuple2
>>转化成Tuple
，即(key, { values })形态。实际上，CoGroupRDD的map方法内部做的事情，是针对每个Key里的Iterator集合，进行了Iterator之间的合并操作。