Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
Вызывает метод с использованием рефлексии.
Синтаксис
from pyspark.sql import functions as sf
sf.reflect(*cols)
Параметры
| Параметр | Тип | Description |
|---|---|---|
cols |
pyspark.sql.Column или str |
Первым элементом должен быть столбец, представляющий литеральную строку для имени класса, а второй элемент должен быть столбцом, представляющим литеральную строку для имени метода, а остальные — входными аргументами (столбцами или именами столбцов) в метод Java. |
Примеры
Пример 1. Отражение вызова метода
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 |
+--------------------------------------+