Hi Is it possible to create a Flink UDF that takes in a data Apache Flink #troubleshooting

Hi. Is it possible to create a Flink UDF that take...

Vitor Leal

10/30/2023, 11:52 AM

Hi. Is it possible to create a Flink UDF that takes in a datatype as an argument? We are trying to create an equivalent to

CONVERT

in SQL Server in Flink. Example

CONVERT(VARCHAR(8), id, 2)

Keyur Makwana

11/03/2023, 6:16 AM

Copy code

public class CONVERT extends ScalarFunction {
    public String eval(String s1,String s2) { //whatever argument you want to give
        //Your logic;
    }
}

Vitor Leal

11/06/2023, 2:28 PM

But

VARCHAR(8)

isn't a string? @Keyur Makwana

Keyur Makwana

11/06/2023, 2:59 PM

I am not sure but I think this should work as Varchar is of type string

Open in Slack

Previous Next