Missing Spark encoder implicit

LorenzBuehmann · LorenzBuehmann · commit a0fb54287a9b · 2017-08-14T08:44:09.000+02:00
diff --git a/sansa-inference-spark/src/main/scala/net/sansa_stack/inference/spark/backwardchaining/BackwardChainingReasonerDataset.scala b/sansa-inference-spark/src/main/scala/net/sansa_stack/inference/spark/backwardchaining/BackwardChainingReasonerDataset.scala
@@ -499,6 +499,7 @@ object BackwardChainingReasonerDataset extends Logging{
   }
 
   def loadDatasetFromParquet(session: SparkSession, path: String): Dataset[RDFTriple] = {
+    import session.implicits._
     session.read.parquet(path).as[RDFTriple]
   }
 

Original file line number	Diff line number	Diff line change
`@@ -499,6 +499,7 @@ object BackwardChainingReasonerDataset extends Logging{`
`499`	`499`	`}`
`500`	`500`
`501`	`501`	`def loadDatasetFromParquet(session: SparkSession, path: String): Dataset[RDFTriple] = {`
	`502`	`+ import session.implicits._`
`502`	`503`	`session.read.parquet(path).as[RDFTriple]`
`503`	`504`	`}`
`504`	`505`