反映する

リフレクションを使用してメソッドを呼び出します。

構文

Python

from pyspark.sql import functions as sf

sf.reflect(*cols)

パラメーター

パラメーター	Type	説明
cols	pyspark.sql.Column または文字列	最初の要素はクラス名のリテラル文字列を表す列、2 番目の要素はメソッド名のリテラル文字列を表す列、残りは Java メソッドへの入力引数 (列または列名) になります。

例

例1 : メソッド呼び出しの反映

Python

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)

Output

+--------------------------------------+
|reflect(java.util.UUID, fromString, a)|
+--------------------------------------+
|a5cf6c42-0c85-418f-af6c-3e4e5b1328f2  |
+--------------------------------------+