package com.test;

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

public class SubFunction extends ScalarFunction {
    public String eval(String s) {
        return "This is java function: "+s;
    }
}