SHARE
TWEET

Untitled

a guest Sep 1st, 2019 75 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  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))
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
 
Top