fix: return Unit is not ok as joint table has to be returned

opentargets · Oct 1, 2018 · c49eb3a · c49eb3a
1 parent 6eb0114
commit c49eb3a
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/src/main/scala/ot/geckopipe/Main.scala b/src/main/scala/ot/geckopipe/Main.scala
@@ -64,14 +64,13 @@ class Commands(val ss: SparkSession, val sampleFactor: Double, val c: Configurat
     val vIdx = vIdxBuilder.load
     val nearests = vIdxBuilder.loadNearestGenes.map( df => {
       logger.info("generate variant index LUT with nearest genes (prot-cod and not prot-cod")
-      val joint = vIdx.table.join(df, VariantIndex.variantColumnNames, "left_outer")
-
-      joint.show(10, false)
-      joint.write.json(c.output.stripSuffix("/").concat("/variant-index-lut/"))
+      vIdx.table.join(df, VariantIndex.variantColumnNames, "left_outer")
     })
 
     nearests match {
-      case scala.util.Success(_) => logger.info("generated variant index LUT")
+      case scala.util.Success(table) =>
+        logger.info("write to json variant index LUT")
+        table.write.json(c.output.stripSuffix("/").concat("/variant-index-lut/"))
       case scala.util.Failure(ex) => logger.error(ex.getMessage)
     }
   }