panbingkun commented on code in PR #41561:
URL: https://github.com/apache/spark/pull/41561#discussion_r1231700253
##########
python/pyspark/sql/connect/functions.py:
##########
@@ -2330,6 +2330,124 @@ def to_number(col: "ColumnOrName", format:
"ColumnOrName") -> Column:
to_number.__doc__ = pysparkfuncs.to_number.__doc__
+def char(col: "ColumnOrName") -> Column:
+ return _invoke_function_over_columns("char", col)
+
+
+char.__doc__ = pysparkfuncs.char.__doc__
+
+
+def btrim(str: "ColumnOrName", trim: Optional["ColumnOrName"] = None) ->
Column:
+ if trim is not None:
+ return _invoke_function_over_columns("btrim", str, trim)
+ else:
+ return _invoke_function_over_columns("btrim", str)
+
+
+btrim.__doc__ = pysparkfuncs.btrim.__doc__
+
+
+def char_length(str: "ColumnOrName") -> Column:
+ return _invoke_function_over_columns("char_length", str)
+
+
+char_length.__doc__ = pysparkfuncs.char_length.__doc__
+
+
+def character_length(str: "ColumnOrName") -> Column:
+ return _invoke_function_over_columns("character_length", str)
+
+
+character_length.__doc__ = pysparkfuncs.character_length.__doc__
+
+
+def chr(col: "ColumnOrName") -> Column:
+ return _invoke_function_over_columns("chr", col)
+
+
+chr.__doc__ = pysparkfuncs.chr.__doc__
+
+
+def contains(left: "ColumnOrName", right: "ColumnOrName") -> Column:
+ return _invoke_function_over_columns("contains", left, right)
+
+
+contains.__doc__ = pysparkfuncs.contains.__doc__
+
+
+def elt(*inputs: "ColumnOrName") -> Column:
+ return _invoke_function("elt", *[_to_col(input) for input in inputs])
+
+
+elt.__doc__ = pysparkfuncs.elt.__doc__
+
+
+def find_in_set(str: "ColumnOrName", str_array: "ColumnOrName") -> Column:
+ return _invoke_function_over_columns("find_in_set", str, str_array)
+
+
+find_in_set.__doc__ = pysparkfuncs.find_in_set.__doc__
+
+
+def like(
+ str: "ColumnOrName", pattern: "ColumnOrName", escapeChar: Optional["char"]
= None
+) -> Column:
+ if escapeChar is not None:
+ return _invoke_function("like", _to_col(str), _to_col(pattern),
lit(escapeChar))
+ else:
+ return _invoke_function("like", _to_col(str), _to_col(pattern))
+
+
+like.__doc__ = pysparkfuncs.like.__doc__
+
+
+def ilike(
+ str: "ColumnOrName", pattern: "ColumnOrName", escapeChar: Optional["char"]
= None
+) -> Column:
+ if escapeChar is not None:
+ return _invoke_function("ilike", _to_col(str), _to_col(pattern),
lit(escapeChar))
+ else:
+ return _invoke_function("ilike", _to_col(str), _to_col(pattern))
+
+
+ilike.__doc__ = pysparkfuncs.ilike.__doc__
+
+
+def lcase(str: "ColumnOrName") -> Column:
+ return _invoke_function_over_columns("lcase", str)
+
+
+lcase.__doc__ = pysparkfuncs.lcase.__doc__
+
+
+def ucase(str: "ColumnOrName") -> Column:
+ return _invoke_function_over_columns("ucase", str)
+
+
+ucase.__doc__ = pysparkfuncs.ucase.__doc__
+
+
+def py_len(str: "ColumnOrName") -> Column:
Review Comment:
ok
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
