?????? Re: flink1.9??blinkSQL??????udf??TIMESTAMP????????
DataType??udf?? import org.apache.flink.table.functions.ScalarFunction; import java.sql.Timestamp; public class UTC2Local extends ScalarFunction { public Timestamp eval(Timestamp s) { long timestamp = s.getTime() + 2880; return new Timestamp(timestamp); } } -- -- ??: "JingsongLee"
?????? Re: Re: flink1.9??blinkSQL??????udf??TIMESTAMP????????
-- -- ??: "user-zh@flink.apache.org Jingso"
?????? Re: Re: flink1.9??blinkSQL??????udf??TIMESTAMP????????
override getResultType public TypeInformation