review comments

apache · Aug 15, 2018 · fb885f4 · fb885f4
1 parent e5d9b05
commit fb885f4
Showing 1 changed file with 6 additions and 9 deletions.
diff --git a/...alyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/higherOrderFunctions.scala b/...alyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/higherOrderFunctions.scala
@@ -518,22 +518,19 @@ case class TransformKeys(
 
   override def nullable: Boolean = argument.nullable
 
+  @transient lazy val MapType(keyType, valueType, valueContainsNull) = argument.dataType
+
   override def dataType: DataType = {
-    val map = argument.dataType.asInstanceOf[MapType]
-    MapType(function.dataType, map.valueType, map.valueContainsNull)
+    MapType(function.dataType, valueType, valueContainsNull)
   }
 
-  @transient lazy val MapType(keyType, valueType, valueContainsNull) = argument.dataType
-
   override def bind(f: (Expression, Seq[(DataType, Boolean)]) => LambdaFunction): TransformKeys = {
     copy(function = f(function, (keyType, false) :: (valueType, valueContainsNull) :: Nil))
   }
 
-  @transient lazy val (keyVar, valueVar) = {
-    @transient lazy val LambdaFunction(
-    _, (keyVar: NamedLambdaVariable) :: (valueVar: NamedLambdaVariable) :: Nil, _) = function
-    (keyVar, valueVar)
-  }
+  @transient lazy val LambdaFunction(
+  _, (keyVar: NamedLambdaVariable) :: (valueVar: NamedLambdaVariable) :: Nil, _) = function
+
 
   override def nullSafeEval(inputRow: InternalRow, argumentValue: Any): Any = {
     val map = argumentValue.asInstanceOf[MapData]