Note
Access to this page requires authorization. You can try signing in or changing directories.
Access to this page requires authorization. You can try changing directories.
Calls a method with reflection.
Syntax
from pyspark.sql import functions as sf
sf.reflect(*cols)
Parameters
| Parameter | Type | Description |
|---|---|---|
cols |
pyspark.sql.Column or str |
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. |
Examples
Example 1: Reflecting a method call
from pyspark.sql import functions as sf
df = spark.createDataFrame([('a5cf6c42-0c85-418f-af6c-3e4e5b1328f2',)], ['a'])
df.select(
sf.reflect(sf.lit('java.util.UUID'), sf.lit('fromString'), 'a')
).show(truncate=False)
+--------------------------------------+
|reflect(java.util.UUID, fromString, a)|
+--------------------------------------+
|a5cf6c42-0c85-418f-af6c-3e4e5b1328f2 |
+--------------------------------------+