Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
akmorrow13 committed Feb 9, 2018
1 parent 026ffad commit 36d11d5
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
11 changes: 6 additions & 5 deletions adam-python/bdgenomics/adam/rdd.py
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down

0 comments on commit 36d11d5

Please sign in to comment.