Saeed Barghi shows us how we can create user-defined functions in Kafka Streams’ KSQL language:
The UDF I want to implement here is DATEADD. If you’re familiar with SQL, you have definitely used it: it takes in a date and adds or subtracts a specific number value to a specific part of datetime, and spits out a new datetime.
To implement a User Defined Function (UDF or UDAF) you would need to code your function in Java and then import the jar file in your KSQL server. You can read about the full process here, I point out a couple of things that I believe you should pay attention to:
I think I prefer Spark’s method for UDFs in Spark SQL: create it in Scala and register the function.