diff --git a/python/pyspark/sql/connect/column.py b/python/pyspark/sql/connect/column.py index b291c5fb21163..c97712100d2a9 100644 --- a/python/pyspark/sql/connect/column.py +++ b/python/pyspark/sql/connect/column.py @@ -46,7 +46,7 @@ class Expression(object): """ __gt__ = _bin_op(">") - __lt__ = _bin_op(">") + __lt__ = _bin_op("<") __add__ = _bin_op("+") __sub__ = _bin_op("-") __mul__ = _bin_op("*") diff --git a/python/pyspark/sql/tests/connect/test_connect_column_expressions.py b/python/pyspark/sql/tests/connect/test_connect_column_expressions.py index ca2cc216ff2f0..a12502047e0ee 100644 --- a/python/pyspark/sql/tests/connect/test_connect_column_expressions.py +++ b/python/pyspark/sql/tests/connect/test_connect_column_expressions.py @@ -57,6 +57,11 @@ def test_column_expressions(self): the protobuf structure.""" df = c.DataFrame.withPlan(p.Read("table")) + expr = fun.lit(10) < fun.lit(10) + expr_plan = expr.to_plan(None) + self.assertIsNotNone(expr_plan.unresolved_function) + self.assertEqual(expr_plan.unresolved_function.parts[0], "<") + expr = df.id % fun.lit(10) == fun.lit(10) expr_plan = expr.to_plan(None) self.assertIsNotNone(expr_plan.unresolved_function)