Function

In DeltaStream, functions refer to user-defined functions that extend DeltaStream's processing capabilities. There are multiple built-in functions available you can use in your queries. You can also create and implement more functions and add them to DeltaStream via function declaration syntax.

There are three types of functions you can declare in DeltaStream.

1. UDFs (User-Defined Functions): These functions can have zero or more arguments and return one value.

2. UDAFs (User-Defined Aggregate Functions): These functions compute values across multiple rows (events) and return one value.

3. UDTFs (User-Defined Table Functions): There functions can have zero or more input arguments, but they return multiple values that can result in multiple rows in the output.

As DeltaStream is powered by Apache Flink, you can implement functions as Apache Flink user-defined functions. For more details, see the corresponding Apache Flink documentation.

Package the implemented functions, plus their dependencies, in a JAR file and upload the JAR file to DeltaStream. Then you can declare a new function and add it to the functions already available in DeltaStream.

You can use the declared function in the expressions in your DeltaStream queries.