租户端 大数据 大数据计算 操作指南 流计算作业开发 自定义开发说明 自定义UDF JAR开发

JAR开发

最近更新时间: 2019-11-11 08:00:19

  • 代码编写 UDF功能需要继承基类ScalarFunction，并重写eval方法。
import org.Apache.Flink.table.functions.ScalarFunction

class UDFTestScala extends ScalarFunction{
def eval(s: String): String = {s}
}
  • 代码打包
mvn clean package -DskipTests -Dcheckstyle.skip=true
  • 页面配置 在资源管理功能中将打包后的streaming-flink-test-1.0-SANPSHOT.jar上传。