Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Registrerar en Java användardefinierad mängdfunktion som en SQL-funktion.
Syntax
registerJavaUDAF(name, javaClassName)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
name |
str | Namnet på den användardefinierade mängdfunktionen. |
javaClassName |
str | Fullständigt kvalificerat namn på Java-klassen. |
Retur
None
Exempel
spark.udf.registerJavaUDAF("javaUDAF", "test.org.apache.spark.sql.MyDoubleAvg")
df = spark.createDataFrame([(1, "a"), (2, "b"), (3, "a")], ["id", "name"])
df.createOrReplaceTempView("df")
q = "SELECT name, javaUDAF(id) as avg from df group by name order by name desc"
spark.sql(q).collect()
# [Row(name='b', avg=102.0), Row(name='a', avg=102.0)]