Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def upateContigSumRange(b:Broadcast[UpdateSumStruct],reducedEvents: RDD[(String,(Array[Short],Int,Int,Int,Int))]) = {
- reducedEvents.map{
- c => {
- val upd = b.value.upd
- val (contig, (eventsArray, minPos, maxPos, contigLength, firstEvent)) = c
- if(upd.get( (contig,minPos) ).nonEmpty)
- (contig, (eventsArray, minPos, maxPos, contigLength, upd((contig, minPos))))
- else
- (contig, (eventsArray, minPos, maxPos, contigLength, new mutable.HashMap[Int, Int]()))
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement