1. 程式人生 > >Apache Flink 零基礎入門(八)Flink支援哪些資料型別

Apache Flink 零基礎入門(八)Flink支援哪些資料型別

Flink有7種資料型別分別是:

  1. Java Tuples and Scala Case Classes
  2. Java POJOs
  3. Primitive Types
  4. Regular Classes
  5. Values
  6. Hadoop Writables
  7. Special Types

Tuple 

Tuple是一個組合資料型別,包含了固定數量的不同類別的欄位。範圍可以從Tuple0到Tuple25,表示包含的欄位數量個數。

POJO

java和scala中定義POJO作用是一樣的,POJO的類要滿足以下條件:

  • 必須用public修飾
  • 必須要有一個public無參建構函式
  • 所有欄位要麼是public的,要麼必須要有setter和getter方法
  • 型別必須是Flink支援的

 Values

需要手動序列化和反序列化

Hadoop Writeables

必須是實現了org.apache.hadoop.Writable的型