diff --git a/adam-core/src/main/scala/org/bdgenomics/adam/rdd/contig/NucleotideContigFragmentRDD.scala b/adam-core/src/main/scala/org/bdgenomics/adam/rdd/contig/NucleotideContigFragmentRDD.scala index ba1d307b7a..64020c0cc4 100644 --- a/adam-core/src/main/scala/org/bdgenomics/adam/rdd/contig/NucleotideContigFragmentRDD.scala +++ b/adam-core/src/main/scala/org/bdgenomics/adam/rdd/contig/NucleotideContigFragmentRDD.scala @@ -136,8 +136,8 @@ case class ParquetUnboundNucleotideContigFragmentRDD private[rdd] ( } case class DatasetBoundNucleotideContigFragmentRDD private[rdd] ( - dataset: Dataset[NucleotideContigFragmentProduct], - sequences: SequenceDictionary) extends NucleotideContigFragmentRDD + dataset: Dataset[NucleotideContigFragmentProduct], + sequences: SequenceDictionary) extends NucleotideContigFragmentRDD with DatasetBoundGenomicDataset[NucleotideContigFragment, NucleotideContigFragmentProduct, NucleotideContigFragmentRDD] { lazy val rdd: RDD[NucleotideContigFragment] = dataset.rdd.map(_.toAvro) diff --git a/adam-python/bdgenomics/adam/rdd.py b/adam-python/bdgenomics/adam/rdd.py index d739caee76..7250fccd95 100644 --- a/adam-python/bdgenomics/adam/rdd.py +++ b/adam-python/bdgenomics/adam/rdd.py @@ -61,14 +61,15 @@ def persist(self, sl): :return: Returns a new, persisted RDD. """ - jsl = self.sc._jvm.org.apache.spark.api.java.StorageLevels.create(sl.useDisk, \ - sl.useMemory, \ - sl.useOffHeap, \ - sl.deserialized, \ - sl.replication) + jsl = self.sc._jvm.org.apache.spark.api.java.StorageLevels.create(sl.useDisk, + sl.useMemory, + sl.useOffHeap, + sl.deserialized, + sl.replication) return self._replaceRdd(self._jvmRdd.persist(jsl)) + def unpersist(self): """ Unpersists underlying RDD from memory or disk.