Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Registriert eine Java benutzerdefinierte Aggregatfunktion als SQL-Funktion.
Syntax
registerJavaUDAF(name, javaClassName)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
name |
str | Name der benutzerdefinierten Aggregatfunktion. |
javaClassName |
str | Vollqualifizierter Name der Java Klasse. |
Rückkehr
None
Beispiele
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)]