最近用到了Flink的自定义函数,在eval转换时,java类型需要与Flink的类型对应起来,网上基本搜索不了,下面来整理下: Flink类型Java类型TINYINTjava.lang.ByteSMALLINTjava.lang.ShortINTjava.lang.IntegerBIGINTjava.lang.LongFLOATjava.lang.FloatDOUBLEjava.lang.DoubleDECIMALjava.math.BigDecimalBOOLEANjava.lang.BooleanDATEjava.sql.DateTIMEjava.sql.TimeTIMESTAMPjava.sql.TimestampCHARjava.lang.CharacterSTRINGjava.lang.StringVARBINARYjava.lang.byte[]ARRAY暂不支持MAP暂不支持