Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Registreert een Java door de gebruiker gedefinieerde statistische functie als een SQL-functie.
Syntaxis
registerJavaUDAF(name, javaClassName)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
name |
str | Naam van de door de gebruiker gedefinieerde statistische functie. |
javaClassName |
str | Volledig gekwalificeerde naam van de klasse Java. |
Retouren
None
Examples
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)]