java_method

Reflektálással meghív egy metódust.

Szemantika

from pyspark.sql import functions as sf

sf.java_method(*cols)

Paraméterek

Paraméter	Típus	Description
cols	pyspark.sql.Column vagy str	Az első elemnek egy oszlopnak kell lennie, amely az osztálynévhez tartozó literális sztringet jelöli, a második elemnek pedig egy oszlopnak kell lennie, amely a metódusnévhez tartozó literális sztringet jelöli, a fennmaradóak pedig a Java-metódus bemeneti argumentumai (oszlopok vagy oszlopnevek).

Példák

1. példa: Metódushívás tükrözése oszlopargumentummal

from pyspark.sql import 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                                         |
+-----------------------------------------------------------------------------+

2. példa: Metódushívás tükrözése oszlopnévargumentummal

from pyspark.sql import 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      |
+------------------------------------------+