Advertisement
Guest User

Untitled

a guest
Sep 1st, 2019
106
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.53 KB | None | 0 0
  1. def upateContigSumRange(b:Broadcast[UpdateSumStruct],reducedEvents: RDD[(String,(Array[Short],Int,Int,Int,Int))]) = {
  2.     reducedEvents.map{
  3.       c => {
  4.         val upd = b.value.upd
  5.  
  6.         val (contig, (eventsArray, minPos, maxPos, contigLength, firstEvent)) = c
  7.         if(upd.get( (contig,minPos) ).nonEmpty)
  8.           (contig, (eventsArray, minPos, maxPos, contigLength, upd((contig, minPos))))
  9.         else
  10.           (contig, (eventsArray, minPos, maxPos, contigLength, new mutable.HashMap[Int, Int]()))
  11.       }
  12.     }
  13.   }
  14. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement