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