CREATE TEMPORARY SYSTEM FUNCTION怎么使用

` TEMPORARY SYSTEM FUNCTION` 是 Flink SQL 中创建自定义系统函数的语法。使用该语法可以将一个 Java 方法注册为 Flink SQL 中的系统函数，从而可以在 SQL 查询中使用该函数。以下是一个示例代码：

public class MyFunction extends ScalarFunction {
    public String eval(String s) {
        return s.toUpperCase();
    }
}

tableEnv.createTemporarySystemFunction("MY_FUNCTION", MyFunction.class);

在上面的代码中，我们定义了一个名为 `MyFunction` 的类，该类继承自 `ScalarFunction`。该类中的 `eval` 方法将字符串转换为大写。然后，我们使用 `createTemporarySystemFunction` 方法将该方法注册为名为 `MY_FUNCTION` 的系统函数。接下来，我们可以在 SQL 查询中使用该函数，例如：

SELECT MY_FUNCTION(name) FROM my_table;

在上面的代码中，我们将 `name` 列中的字符串转换为大写。注意，使用 `CREATE TEMPORARY SYSTEM FUNCTION` 创建的系统函数只在当前作用域内有效，如果需要在多个查询中使用该函数，则需要在每个查询中都注册一次。另外，如果需要将系统函数注册为全局函数，则可以使用 `CREATE FUNCTION` 语法。