reducedEvents .persist(StorageLevel.MEMORY_AND_DISK) .foreach(x => { val maxC = x._2._2 + x._2._1.length - 1 if (!targetType.equals(StringType)) { val maxCounter = if (targetType.equals(IntegerType)) maxC % windowLength.get else // Blocks and bases for faster computing 1 val rightCovSumEdge = RightCovSumEdge(x._1, maxC, x._2._1.takeRight(maxCounter)) val rightCovSumUpdate = new CovSumUpdate(ArrayBuffer(rightCovSumEdge))