现有 //中间那个5,是bitset的数量 tmp_trans:RDD[(Int,Int,java.util.BitSet)] = [(5,5,{1,2,3,4,5}),(3,5,{3,4,5,6,7})] //我希望得到 result:RDD[(Array(Int),Int,java.util.BitSet)] =[(5,3),3,{3,4,5}] //即_1合并成(5,3),_3相交成{3,4,5}
相似问题