Condividi tramite


udf (SparkSession)

Restituisce un oggetto UDFRegistration per la registrazione della funzione definita dall'utente.

Sintassi

udf

Restituzioni

UDFRegistration

Examples

# Register a Python UDF, and use it in SQL.
strlen = spark.udf.register("strlen", lambda x: len(x))
spark.sql("SELECT strlen('test')").show()
# +------------+
# |strlen(test)|
# +------------+
# |           4|
# +------------+