Advertisement
Guest User

Untitled

a guest
Sep 1st, 2019
110
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.51 KB | None | 0 0
  1.  reducedEvents
  2.       .persist(StorageLevel.MEMORY_AND_DISK)
  3.       .foreach(x => {
  4.         val maxC = x._2._2 + x._2._1.length - 1
  5.         if (!targetType.equals(StringType)) {
  6.           val maxCounter = if (targetType.equals(IntegerType))
  7.             maxC % windowLength.get
  8.           else // Blocks and bases for faster computing
  9.             1
  10.           val rightCovSumEdge = RightCovSumEdge(x._1, maxC, x._2._1.takeRight(maxCounter))
  11.           val rightCovSumUpdate = new CovSumUpdate(ArrayBuffer(rightCovSumEdge))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement