最近用到了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 | 暂不支持 |