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));