flinksql 自定义函数代码

Flink SQL 中可以自定义函数，以下是一个示例代码：

import org.apache.flink.table.functions.ScalarFunction;

public class Upper extends ScalarFunction {
  public String eval(String s) {
    if (s == null) {
      return null;
    }
    return s.toUpperCase();
  }
}

在上面的代码中，我们定义了一个名为 Upper 的自定义函数，它继承了 ScalarFunction 类，实现了 eval 方法。eval 方法接收一个字符串参数 s，将其转换成大写并返回。

接下来，我们需要将该函数注册到 Flink SQL 的环境中：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

tableEnv.registerFunction("upper", new Upper());

在上面的代码中，我们创建了一个 StreamExecutionEnvironment 对象和一个 StreamTableEnvironment 对象，并将 Upper 函数注册到了 tableEnv 中，其中 "upper" 是函数的名称，new Upper() 是函数的实例。

现在，我们可以在 SQL 语句中使用该函数了：

SELECT upper(name) FROM myTable;