最近用到了Flink的自定义函数,在eval转换时,java类型需要与Flink的类型对应起来,网上基本搜索不了,下面来整理下:
| Flink类型 | Java类型 |
|---|---|
| TINYINT | java.lang.Byte |
| SMALLINT | java.lang.Short |
| INT | java.lang.Integer |
| BIGINT | java.lang.Long |
| FLOAT | java.lang.Float |
| DOUBLE | java.lang.Double |
| DECIMAL | java.math.BigDecimal |
| BOOLEAN | java.lang.Boolean |
| DATE | java.sql.Date |
| TIME | java.sql.Time |
| TIMESTAMP | java.sql.Timestamp |
| CHAR | java.lang.Character |
| STRING | java.lang.String |
| VARBINARY | java.lang.byte[] |
| ARRAY | 暂不支持 |
| MAP | 暂不支持 |









