From 38103728c1dc86b660ba5c60eba0088429f7cb3d Mon Sep 17 00:00:00 2001 From: Peter van 't Hof Date: Sat, 15 Jul 2017 10:36:38 +0200 Subject: [PATCH] Fixing some compile issues --- .../scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStats.scala | 2 -- .../nl/lumc/sasc/biopet/tools/vcfstats/VcfStatsSpark.scala | 6 ++---- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/biopet-tools/src/main/scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStats.scala b/biopet-tools/src/main/scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStats.scala index 033f32d10..1fa5c8e9c 100644 --- a/biopet-tools/src/main/scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStats.scala +++ b/biopet-tools/src/main/scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStats.scala @@ -643,8 +643,6 @@ object VcfStats extends ToolCommand { val absFile = new File(prefix + ".abs.tsv") val relFile = new File(prefix + ".rel.tsv") - stats.getContigStats() - absFile.getParentFile.mkdirs() val absWriter = new PrintWriter(absFile) diff --git a/biopet-tools/src/main/scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStatsSpark.scala b/biopet-tools/src/main/scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStatsSpark.scala index 39fdfa58f..e95de1f1c 100644 --- a/biopet-tools/src/main/scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStatsSpark.scala +++ b/biopet-tools/src/main/scala/nl/lumc/sasc/biopet/tools/vcfstats/VcfStatsSpark.scala @@ -3,7 +3,7 @@ package nl.lumc.sasc.biopet.tools.vcfstats import java.io.{File, PrintWriter} import htsjdk.variant.vcf.VCFFileReader -import nl.lumc.sasc.biopet.tools.vcfstats.VcfStats.{cmdArgs, _} +import nl.lumc.sasc.biopet.tools.vcfstats.VcfStats._ import nl.lumc.sasc.biopet.utils.{ConfigUtils, FastaUtils, ToolCommand, VcfUtils} import nl.lumc.sasc.biopet.utils.intervals.{BedRecord, BedRecordList} import org.apache.spark.{SparkConf, SparkContext} @@ -137,7 +137,7 @@ object VcfStatsSpark extends ToolCommand { val regionStats = sc.parallelize(regions, regions.size).groupBy(_.chr).map { case (contig, records) => contig -> records.map(readBin(_, samples, cmdArgs, adInfoTags, adGenotypeTags))} - val chrStats = regionStats.map {case (contig, stats) => contig -> stats.reduce(_ += _)}.cache() + val chrStats = regionStats.map {case (contig, stats) => contig -> stats.reduce(_ += _)} val totalStats = chrStats.values.reduce(_ += _) @@ -163,8 +163,6 @@ object VcfStatsSpark extends ToolCommand { cmdArgs.outputDir + "/sample_compare/allele_overlap", samples) - Thread.sleep(1000000) - sc.stop logger.info("Done") } -- GitLab