# Define and register a UDF
from risingwave.udf import udf, UdfServer
@udf(input_types=["VARCHAR"], result_type="VARCHAR")
def normalize_email(email: str) -> str:
return email.strip().lower()
server = UdfServer(location="0.0.0.0:8815")
server.add_function(normalize_email)
server.serve()Ask this repo
Ask risingwavelabs/risingwave a question
Answers cite the files and lines they came from. Open a citation to check it.