?????? Re: flink1.9??blinkSQL??????udf??TIMESTAMP????????

2019-09-04 Thread ???? 
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????????

2019-09-05 Thread ???? 





--  --
??: "user-zh@flink.apache.org Jingso"

?????? Re: Re: flink1.9??blinkSQL??????udf??TIMESTAMP????????

2019-09-05 Thread ???? 
override getResultType


public TypeInformation