Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement