Flink有7种数据类型分别是:java
- Java Tuples and Scala Case Classes
- Java POJOs
- Primitive Types
- Regular Classes
- Values
- Hadoop Writables
- Special Types
Tuple
Tuple是一个组合数据类型,包含了固定数量的不一样类别的字段。范围能够从Tuple0到Tuple25,表示包含的字段数量个数。apache
POJO
java和scala中定义POJO做用是同样的,POJO的类要知足如下条件:函数
- 必须用public修饰
- 必需要有一个public无参构造函数
- 全部字段要么是public的,要么必需要有setter和getter方法
- 类型必须是Flink支持的
Values
须要手动序列化和反序列化oop
Hadoop Writeables
必须是实现了org.apache.hadoop.Writable的类型。spa