Skip to content

Commit

Permalink
[ADAM-513] Remove ReferenceMappable trait.
Browse files Browse the repository at this point in the history
  • Loading branch information
fnothaft committed Feb 25, 2015
1 parent 94f4841 commit c404316
Show file tree
Hide file tree
Showing 14 changed files with 76 additions and 626 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,6 @@ object ADAMMain extends Logging {
PrintADAM,
PrintGenes,
FlagStat,
VizReads,
PrintTags,
ListDict,
SummarizeGenotypes,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ import org.bdgenomics.adam.projections.Projection
import org.bdgenomics.adam.projections.AlignmentRecordField._
import org.bdgenomics.adam.rdd.ADAMContext._
import org.bdgenomics.adam.rdd.BroadcastRegionJoin
import org.bdgenomics.adam.rich.ReferenceMappingContext._
import org.bdgenomics.formats.avro.AlignmentRecord
import scala.io._

Expand Down Expand Up @@ -90,8 +89,8 @@ class CalculateDepth(protected val args: CalculateDepthArgs) extends ADAMSparkCo
val variantNames = vcf.collect().toMap

val joinedRDD: RDD[(ReferenceRegion, AlignmentRecord)] =
if (args.cartesian) BroadcastRegionJoin.cartesianFilter(variantPositions, mappedRDD)
else BroadcastRegionJoin.partitionAndJoin(sc, variantPositions, mappedRDD)
if (args.cartesian) BroadcastRegionJoin.cartesianFilter(variantPositions.keyBy(v => v), mappedRDD.keyBy(ReferenceRegion(_).get))
else BroadcastRegionJoin.partitionAndJoin(sc, variantPositions.keyBy(v => v), mappedRDD.keyBy(ReferenceRegion(_).get))

val depths: RDD[(ReferenceRegion, Int)] =
joinedRDD.map { case (region, record) => (region, 1) }.reduceByKey(_ + _).sortByKey()
Expand Down
230 changes: 0 additions & 230 deletions adam-cli/src/main/scala/org/bdgenomics/adam/cli/VizReads.scala

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit c404316

Please sign in to comment.