SHARE
TWEET

Untitled

a guest Sep 1st, 2019 83 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  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. }
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