簡介
Flink 流應(yīng)用程序處理的是以數(shù)據(jù)對象表示的事件流兵迅，所有我們需要能夠處理這些對象，他們需要被序列化和反序列化琼懊，以便通過網(wǎng)絡(luò)傳遞他們枯跑，或者從狀態(tài)后端愧哟，檢查點(diǎn)，和保存點(diǎn)讀取他們。為了有效的做到這一點(diǎn)，F(xiàn)link 使用類型信息的概念表示數(shù)據(jù)類型拾并，并為每個數(shù)據(jù)類型生成特定的序列化和反序列化器和比較器。
Flink 還具有一個類型提取系統(tǒng)鹏浅，該系統(tǒng)分析函數(shù)的輸入和返回類型嗅义，以自動獲取類型的信息，從而獲得序列化器和反系列化器篡石。但是芥喇，在某些情況下，例如：lambda函數(shù)凰萨，或者泛型類型，需要顯式的提供類型信息械馆，才能使應(yīng)用程序工作正常工作胖眷，或提高其性能。
Flink 支持Java 和scala 中所有常見的數(shù)據(jù)類型霹崎，使用最廣泛的有：
java 和 Scala 基礎(chǔ)數(shù)據(jù)類型
Int 珊搀，Long ,Double ,String ,
