跳到主要内容
版本：2.1.3

udf

Description​

Supports using UDF in data integration by the transform. Need to specify the function name and class name and put UDF jars in Flink's classpath or import them via 'Flink run -c xxx.jar'

提示

This transform ONLY supported by Flink.

Options​

nametyperequireddefault value
functionstringyes-

function [string]​

A config prefix, use like function.test="xxx.Test".

common options [string]​

Transform plugin common parameters, please refer to Transform Plugin for details

Examples​

Use udf in sql.

  udf {
    function.test_1 = "com.example.udf.flink.TestUDF"
    function.test_2 = "com.example.udf.flink.TestUDTF"
  }
  
  # Use the specify function (confirm that the fake table exists)
  sql {
    sql = "select test_1(name), age from fake"
  }