Skip to content

Commit 8bf64a7

Browse files
committed
revert In change
1 parent ba60472 commit 8bf64a7

File tree

2 files changed

+1
-5
lines changed

2 files changed

+1
-5
lines changed

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -442,10 +442,6 @@ case class InSubquery(values: Seq[Expression], query: ListQuery)
442442
// scalastyle:on line.size.limit
443443
case class In(value: Expression, list: Seq[Expression]) extends Predicate {
444444

445-
def this(valueAndList: Seq[Expression]) = {
446-
this(valueAndList.head, valueAndList.tail)
447-
}
448-
449445
require(list != null, "list should not be null")
450446

451447
override def checkInputDataTypes(): TypeCheckResult = {

sql/core/src/main/scala/org/apache/spark/sql/Column.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -814,7 +814,7 @@ class Column(val expr: Expression) extends Logging {
814814
* @since 1.5.0
815815
*/
816816
@scala.annotation.varargs
817-
def isin(list: Any*): Column = Column.fn("in", this +: list.map(lit): _*)
817+
def isin(list: Any*): Column = withExpr { In(expr, list.map(lit(_).expr)) }
818818

819819
/**
820820
* A boolean expression that is evaluated to true if the value of this expression is contained

0 commit comments

Comments
 (0)