Flink使用Table和SQL语法操作Hive（Java版）

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

// 定义函数逻辑
public class SubstringFunction extends ScalarFunction {
    public String eval(String s, Integer begin, Integer end) {
        return s.substring(begin, end);
    }
}

tableEnv.from("MyTable").select(call(new SubstringFunction(true), $("myField"), 5, 12));

// 注册函数
tableEnv.createTemporarySystemFunction("SubstringFunction", SubstringFunction.class);

tableEnv.from("MyTable").select(call("SubstringFunction", $("myField"),5, 12));