Skip to content

Latest commit

 

History

History
8 lines (7 loc) · 796 Bytes

File metadata and controls

8 lines (7 loc) · 796 Bytes

Creating JBang UDFs

  1. Structure: The usrlib contains a sample Java UDF file, but any folder name or subfolder can be used inside the DataSQRL project root.
  2. Defining the Function: The main component of this project is the MyScalarFunction class. This is the implementation of a custom flink function. DataSQRL recognizes flink functions that extend any base Flink UDF class.
  3. Defining Dependencies: To fetch dependencies JBang will look for lines that start with //DEPS and define a proper artifact. The bare minimum that any Flink UDF will require is flink-table-common, because the custom UDF has to extend a Flink built-in UDF parent class.
  4. JAR Compiling: The compile and JAR build is handled by JBang, that DataSQRL will do automatically on the fly.