Bagikan melalui


java_method

Memanggil metode dengan refleksi.

Syntax

from pyspark.sql import functions as sf

sf.java_method(*cols)

Parameter-parameternya

Pengaturan Tipe Description
cols pyspark.sql.Column atau str Elemen pertama harus berupa Kolom yang mewakili string harfiah untuk nama kelas, dan elemen kedua harus berupa Kolom yang mewakili string harfiah untuk nama metode, dan yang tersisa adalah argumen input (Kolom atau nama kolom) ke metode Java.

Examples

Contoh 1: Mencerminkan panggilan metode dengan argumen kolom

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

Contoh 2: Mencerminkan panggilan metode dengan argumen nama kolom

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