[jira] [Created] (FLINK-28813) new stach builtinfunction validateClassForRuntime it not correct

["jackylau (Jira)" <ji...@apache.org>]

jackylau created FLINK-28813:
--------------------------------

             Summary: new stach builtinfunction  validateClassForRuntime it not correct
                 Key: FLINK-28813
                 URL: https://issues.apache.org/jira/browse/FLINK-28813
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner
    Affects Versions: 1.16.0
            Reporter: jackylau
             Fix For: 1.16.0


{code:java}
org.apache.flink.table.api.ValidationException: Could not find an implementation method 'eval' in class 'org.apache.flink.table.runtime.functions.scalar.ConvFunction' for function 'CONV' that matches the following signature:
org.apache.flink.table.data.StringData eval(org.apache.flink.table.data.StringData, java.lang.Byte, java.lang.Integer)  at org.apache.flink.table.functions.UserDefinedFunctionHelper.validateClassForRuntime(UserDefinedFunctionHelper.java:319) {code}
{code:java}
// code placeholder
public class ConvFunction extends BuiltInScalarFunction {

    public ConvFunction(SpecializedFunction.SpecializedContext context) {
        super(BuiltInFunctionDefinitions.CONV, context);
    }

    public static StringData eval(StringData input, Integer fromBase, Integer toBase) {
        if (input == null || fromBase == null || toBase == null) {
            return null;
        }
        return StringData.fromString(BaseConversionUtils.conv(input.toBytes(), fromBase, toBase));
    }

    public static StringData eval(long input, Integer fromBase, Integer toBase) {
        return eval(StringData.fromString(String.valueOf(input)), fromBase, toBase);
    }
}


@Test
public void testRowScalarFunction1() throws Exception {
    tEnv().executeSql(
                    "CREATE TABLE TestTable(s STRING) " + "WITH ('connector' = 'COLLECTION')");

    // the names of the function input and r differ
    tEnv().executeSql("INSERT INTO TestTable select conv(3, cast(1 AS TINYINT), 4)").await();

} {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)