Catatan
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba masuk atau mengubah direktori.
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba mengubah direktori.
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 |
+------------------------------------------+