Skip to content

Commit

Permalink
Rename sequences SequenceDictionary field to references.
Browse files Browse the repository at this point in the history
  • Loading branch information
heuermh committed Feb 12, 2021
1 parent 385fda3 commit 8574aaf
Show file tree
Hide file tree
Showing 41 changed files with 616 additions and 629 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -595,7 +595,7 @@ class TransformAlignments(protected val args: TransformAlignmentsArgs) extends B
}

val rdd = aDs.rdd
val sd = aDs.sequences
val sd = aDs.references
val rgd = aDs.readGroups
val pgs = aDs.processingSteps

Expand All @@ -619,7 +619,7 @@ class TransformAlignments(protected val args: TransformAlignmentsArgs) extends B

// if we have a second rdd that we are merging in, process the merger here
val (mergedRdd, mergedSd, mergedRgd, mergedPgs) = concatOpt.fold((rdd, sd, rgd, pgs))(t => {
(rdd ++ t.rdd, sd ++ t.sequences, rgd ++ t.readGroups, pgs ++ t.processingSteps)
(rdd ++ t.rdd, sd ++ t.references, rgd ++ t.readGroups, pgs ++ t.processingSteps)
})

// make a new aligned read rdd, that merges the two RDDs together
Expand All @@ -637,7 +637,7 @@ class TransformAlignments(protected val args: TransformAlignmentsArgs) extends B
}

if (args.partitionByStartPos) {
if (outputDs.sequences.isEmpty) {
if (outputDs.references.isEmpty) {
warn("This dataset is not aligned and therefore will not benefit from being saved as a partitioned dataset")
}
outputDs.saveAsPartitionedParquet(args.outputPath, partitionSize = args.partitionedBinSize)
Expand Down
Loading

0 comments on commit 8574aaf

Please sign in to comment.