Pular para o conteúdo principal

refletir

Chama um método com reflexão.

Sintaxe

Python
from pyspark.sql import functions as sf

sf.reflect(*cols)

Parâmetros

Parâmetro

Tipo

Descrição

cols

pyspark.sql.Column ou str

O primeiro elemento deve ser uma coluna representando strings literais para o nome da classe, o segundo elemento deve ser uma coluna representando strings literais para o nome do método e os restantes são argumentos de entrada (colunas ou nomes de colunas) para o método Java .

Exemplos

Exemplo 1 : Refletindo uma chamada de método

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 |
+--------------------------------------+