Skip to content

Commit

Permalink
fixed missing extends typoe tin DataBoundAlignmentRecordRDD
Browse files Browse the repository at this point in the history
  • Loading branch information
jpdna committed Feb 17, 2018
1 parent 211072b commit 5c29dde
Show file tree
Hide file tree
Showing 7 changed files with 32 additions and 33 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2560,6 +2560,7 @@ abstract class AvroGenomicRDD[T <% IndexedRecord: Manifest, U <: Product, V <: A
"\' and (end > " + r.start + " and start < " + r.end + "))")
.mkString(" or ")
}

}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -136,12 +136,10 @@ case class ParquetUnboundNucleotideContigFragmentRDD private[rdd] (
}

case class DatasetBoundNucleotideContigFragmentRDD private[rdd] (
dataset: Dataset[NucleotideContigFragmentProduct],
sequences: SequenceDictionary,
partitionedBinSize: Option[Int] = None) extends NucleotideContigFragmentRDD
with DatasetBoundGenomicDataset[NucleotideContigFragment,
NucleotideContigFragmentProduct,
NucleotideContigFragmentRDD] {
dataset: Dataset[NucleotideContigFragmentProduct],
sequences: SequenceDictionary,
partitionedBinSize: Option[Int] = None) extends NucleotideContigFragmentRDD
with DatasetBoundGenomicDataset[NucleotideContigFragment, NucleotideContigFragmentProduct, NucleotideContigFragmentRDD] {
lazy val rdd: RDD[NucleotideContigFragment] = dataset.rdd.map(_.toAvro)

protected lazy val optPartitionMap = None
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -275,10 +275,10 @@ case class ParquetUnboundFeatureRDD private[rdd] (
}

case class DatasetBoundFeatureRDD private[rdd] (
dataset: Dataset[FeatureProduct],
sequences: SequenceDictionary,
partitionedBinSize: Option[Int] = None) extends FeatureRDD
with DatasetBoundGenomicDataset[Feature, FeatureProduct, FeatureRDD] {
dataset: Dataset[FeatureProduct],
sequences: SequenceDictionary,
partitionedBinSize: Option[Int] = None) extends FeatureRDD
with DatasetBoundGenomicDataset[Feature, FeatureProduct, FeatureRDD] {

lazy val rdd = dataset.rdd.map(_.toAvro)
protected lazy val optPartitionMap = None
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -184,12 +184,12 @@ case class ParquetUnboundFragmentRDD private[rdd] (
}

case class DatasetBoundFragmentRDD private[rdd] (
dataset: Dataset[FragmentProduct],
sequences: SequenceDictionary,
recordGroups: RecordGroupDictionary,
@transient val processingSteps: Seq[ProcessingStep],
partitionedBinSize: Option[Int] = None) extends FragmentRDD
with DatasetBoundGenomicDataset[Fragment, FragmentProduct, FragmentRDD] {
dataset: Dataset[FragmentProduct],
sequences: SequenceDictionary,
recordGroups: RecordGroupDictionary,
@transient val processingSteps: Seq[ProcessingStep],
partitionedBinSize: Option[Int] = None) extends FragmentRDD
with DatasetBoundGenomicDataset[Fragment, FragmentProduct, FragmentRDD] {

lazy val rdd = dataset.rdd.map(_.toAvro)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -234,12 +234,12 @@ case class ParquetUnboundAlignmentRecordRDD private[rdd] (
}

case class DatasetBoundAlignmentRecordRDD private[rdd] (
dataset: Dataset[AlignmentRecordProduct],
sequences: SequenceDictionary,
recordGroups: RecordGroupDictionary,
@transient val processingSteps: Seq[ProcessingStep],
partitionedBinSize: Option[Int] = None) extends
with DatasetBoundGenomicDataset[AlignmentRecord, AlignmentRecordProduct, AlignmentRecordRDD] {
dataset: Dataset[AlignmentRecordProduct],
sequences: SequenceDictionary,
recordGroups: RecordGroupDictionary,
@transient val processingSteps: Seq[ProcessingStep],
partitionedBinSize: Option[Int] = None) extends AlignmentRecordRDD
with DatasetBoundGenomicDataset[AlignmentRecord, AlignmentRecordProduct, AlignmentRecordRDD] {

lazy val rdd = dataset.rdd.map(_.toAvro)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -142,12 +142,12 @@ case class ParquetUnboundGenotypeRDD private[rdd] (
}

case class DatasetBoundGenotypeRDD private[rdd] (
dataset: Dataset[GenotypeProduct],
sequences: SequenceDictionary,
@transient samples: Seq[Sample],
@transient headerLines: Seq[VCFHeaderLine] = DefaultHeaderLines.allHeaderLines,
partitionedBinSize: Option[Int] = None) extends GenotypeRDD
with DatasetBoundGenomicDataset[Genotype, GenotypeProduct, GenotypeRDD] {
dataset: Dataset[GenotypeProduct],
sequences: SequenceDictionary,
@transient samples: Seq[Sample],
@transient headerLines: Seq[VCFHeaderLine] = DefaultHeaderLines.allHeaderLines,
partitionedBinSize: Option[Int] = None) extends GenotypeRDD
with DatasetBoundGenomicDataset[Genotype, GenotypeProduct, GenotypeRDD] {

protected lazy val optPartitionMap = None

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -133,11 +133,11 @@ case class ParquetUnboundVariantRDD private[rdd] (
}

case class DatasetBoundVariantRDD private[rdd] (
dataset: Dataset[VariantProduct],
sequences: SequenceDictionary,
@transient headerLines: Seq[VCFHeaderLine] = DefaultHeaderLines.allHeaderLines,
partitionedBinSize: Option[Int] = None) extends VariantRDD
with DatasetBoundGenomicDataset[Variant, VariantProduct, VariantRDD] {
dataset: Dataset[VariantProduct],
sequences: SequenceDictionary,
@transient headerLines: Seq[VCFHeaderLine] = DefaultHeaderLines.allHeaderLines,
partitionedBinSize: Option[Int] = None) extends VariantRDD
with DatasetBoundGenomicDataset[Variant, VariantProduct, VariantRDD] {

protected lazy val optPartitionMap = None

Expand Down

0 comments on commit 5c29dde

Please sign in to comment.