From 736df967a1a323edc54b561615e5bffe6dd34e85 Mon Sep 17 00:00:00 2001 From: Michael Weil <42453257+michaelweilsalesforce@users.noreply.github.com> Date: Thu, 27 Jun 2019 12:34:57 -0700 Subject: [PATCH] Quick Fix Alias Type Names (#346) --- .../main/scala/com/salesforce/op/readers/JoinedDataReader.scala | 2 +- readers/src/main/scala/com/salesforce/op/readers/Reader.scala | 2 +- 2 files changed, 2 insertions(+), 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 index 7b9b8a5ab3..c52164b575 100644 --- 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 index a41c51e612..25fe4ef803 100644 --- 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