???????????????? sql ????????????????????
???????????? 1.12.0???????????????? Timestamp ??
UDF?????????????????? @DataTypeHint ???????? Timestamp ?????? sql ??
timestame(3) ???????????????????? timestame(9)??????????????????public static
class ToTimestamp extends ScalarFunction {
public static final String FUNCTION_NAME = "TO_TIMESTAMP";
private static final long serialVersionUID = -2859363577738468502L;
public @DataTypeHint(value = "TIMESTAMP(3)", bridgedTo =
java.sql.Timestamp.class)
Timestamp eval(Long time) {
return new Timestamp(time);
}
}
???????? org.apache.flink.table.types.utils.ClassDataTypeConverter
????????????????????????????????????????????????????????????????
