Quick Fix Alias Type Names (#346)

salesforce · Jun 27, 2019 · 736df96 · 736df96
1 parent e552147
commit 736df96
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/readers/src/main/scala/com/salesforce/op/readers/JoinedDataReader.scala b/readers/src/main/scala/com/salesforce/op/readers/JoinedDataReader.scala
@@ -149,7 +149,7 @@ private[op] abstract class JoinedReader[T, U]
   )(implicit spark: SparkSession): (DataFrame, Array[String]) = {
 
     def getData(r: DataReader[_]): DataFrame = {
-      val readerFeatures = rawFeatures.filter { f => getGenStage(f).tti.tpe.typeSymbol.fullName == r.fullTypeName }
+      val readerFeatures = rawFeatures.filter { f => getGenStage(f).tti.tpe.toString == r.fullTypeName }
       r.generateDataFrame(readerFeatures, opParams)
     }
 

diff --git a/readers/src/main/scala/com/salesforce/op/readers/Reader.scala b/readers/src/main/scala/com/salesforce/op/readers/Reader.scala
@@ -51,7 +51,7 @@ private[readers] trait ReaderType[T] extends Serializable {
    *
    * @return full input type name
    */
-  final def fullTypeName: String = wtt.tpe.typeSymbol.fullName
+  final def fullTypeName: String = wtt.tpe.toString
 
   /**
    * Short reader input type name