|
new InterruptibleIterator(context, aggregator.combineCombinersByKey(iter)) |
type mismatch; found : Iterator[(Int, (Int, (it.unimi.dsi.fastutil.ints.IntArrayList, it.unimi.dsi.fastutil.doubles.DoubleArrayList)))] required: Iterator[_ <: Product2[Int,(it.unimi.dsi.fastutil.ints.IntArrayList,
it.unimi.dsi.fastutil.doubles.DoubleArrayList)]]