java_method

Roept een methode aan met weerspiegeling.

Syntaxis

from pyspark.sql import functions as sf

sf.java_method(*cols)

Parameterwaarden

Kenmerk	Typologie	Description
cols	pyspark.sql.Column of str	Het eerste element moet een kolom zijn die de letterlijke tekenreeks voor de klassenaam vertegenwoordigt. Het tweede element moet een kolom zijn die de letterlijke tekenreeks voor de methodenaam vertegenwoordigt en de resterende invoerargumenten (kolommen of kolomnamen) zijn voor de Java-methode.

Voorbeelden

Voorbeeld 1: Een methode-aanroep weergeven met een kolomargument

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

Voorbeeld 2: Een methode-aanroep weergeven met een kolomnaamargument

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