pyspark.sql.functions.java_method

pyspark.sql.functions.java_method(*cols)

Calls a method with reflection.

New in version 3.5.0.

Parameters

colsColumn or column name

the first element should be a Column representing literal string for the class name, and the second element should be a Column representing literal string for the method name, and the remaining are input arguments (Columns or column names) to the Java method.

See also

pyspark.sql.functions.reflect()

pyspark.sql.functions.try_reflect()

Examples

Example 1: Reflecting a method call with a column argument

>>> import pyspark.sql.functions as sf
>>> spark.range(1).select(
...     sf.java_method(
...         sf.lit("java.util.UUID"),
...         sf.lit("fromString"),
...         sf.lit("a5cf6c42-0c85-418f-af6c-3e4e5b1328f2")
...     )
... ).show(truncate=False)
+-----------------------------------------------------------------------------+
|java_method(java.util.UUID, fromString, a5cf6c42-0c85-418f-af6c-3e4e5b1328f2)|
+-----------------------------------------------------------------------------+
|a5cf6c42-0c85-418f-af6c-3e4e5b1328f2                                         |
+-----------------------------------------------------------------------------+

Example 2: Reflecting a method call with a column name argument

>>> import pyspark.sql.functions as sf
>>> df = spark.createDataFrame([('a5cf6c42-0c85-418f-af6c-3e4e5b1328f2',)], ['a'])
>>> df.select(
...     sf.java_method(sf.lit('java.util.UUID'), sf.lit('fromString'), 'a')
... ).show(truncate=False)
+------------------------------------------+
|java_method(java.util.UUID, fromString, a)|
+------------------------------------------+
|a5cf6c42-0c85-418f-af6c-3e4e5b1328f2      |
+------------------------------------------+