Skip to content

Commit 968ffb3

Browse files
committed
revert_sql
1 parent 1de531c commit 968ffb3

File tree

2 files changed

+4
-12
lines changed

2 files changed

+4
-12
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2971,7 +2971,7 @@ trait ArraySetLike {
29712971
protected def genGetValue(array: String, i: String): String =
29722972
CodeGenerator.getValue(array, et, i)
29732973

2974-
@transient private lazy val tuple = {
2974+
@transient protected lazy val (hsPostFix, hsTypeName) = {
29752975
val ptName = CodeGenerator.primitiveTypeName(et)
29762976
et match {
29772977
// we cast byte/short to int when writing to the hash set.
@@ -2981,8 +2981,6 @@ trait ArraySetLike {
29812981
case DoubleType => ("$mcD$sp", ptName)
29822982
}
29832983
}
2984-
@transient protected lazy val hsPostFix = tuple._1
2985-
@transient protected lazy val hsTypeName = tuple._2
29862984

29872985
// we cast byte/short to int when writing to the hash set.
29882986
@transient protected lazy val hsValueCast = et match {

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/higherOrderFunctions.scala

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -257,7 +257,7 @@ case class ArrayTransform(
257257
}
258258
}
259259

260-
@transient private lazy val tuple = {
260+
@transient lazy val (elementVar, indexVar) = {
261261
val LambdaFunction(_, (elementVar: NamedLambdaVariable) +: tail, _) = function
262262
val indexVar = if (tail.nonEmpty) {
263263
Some(tail.head.asInstanceOf[NamedLambdaVariable])
@@ -266,8 +266,6 @@ case class ArrayTransform(
266266
}
267267
(elementVar, indexVar)
268268
}
269-
@transient lazy val elementVar = tuple._1
270-
@transient lazy val indexVar = tuple._2
271269

272270
override def nullSafeEval(inputRow: InternalRow, argumentValue: Any): Any = {
273271
val arr = argumentValue.asInstanceOf[ArrayData]
@@ -411,12 +409,10 @@ case class MapFilter(
411409
function: Expression)
412410
extends MapBasedSimpleHigherOrderFunction with CodegenFallback {
413411

414-
@transient private lazy val tuple = {
412+
@transient lazy val (keyVar, valueVar) = {
415413
val args = function.asInstanceOf[LambdaFunction].arguments
416414
(args.head.asInstanceOf[NamedLambdaVariable], args.tail.head.asInstanceOf[NamedLambdaVariable])
417415
}
418-
@transient lazy val keyVar = tuple._1
419-
@transient lazy val valueVar = tuple._2
420416

421417
@transient lazy val MapType(keyType, valueType, valueContainsNull) = argument.dataType
422418

@@ -482,13 +478,11 @@ case class ArrayFilter(
482478
}
483479
}
484480

485-
@transient private lazy val tuple = {
481+
@transient lazy val (elementVar, indexVar) = {
486482
val LambdaFunction(_, (elementVar: NamedLambdaVariable) +: tail, _) = function
487483
val indexVar = tail.headOption.map(_.asInstanceOf[NamedLambdaVariable])
488484
(elementVar, indexVar)
489485
}
490-
@transient lazy val elementVar = tuple._1
491-
@transient lazy val indexVar = tuple._2
492486

493487
override def nullSafeEval(inputRow: InternalRow, argumentValue: Any): Any = {
494488
val arr = argumentValue.asInstanceOf[ArrayData]

0 commit comments

Comments
 (0)