Flink Scala Api擴充套件

1.Flink Scala Api在預設不啟用，使用類似Java的寫法，如果需要使用Scala的寫法，則需要擴充套件
2. 為了在Scala和Java api之間保持相當的一致性，一些允許Scala高表達性的特性已經從標準api中被忽略了，它們都是批量和流的。
3. 如果您希望享受完整的Scala體驗，您可以選擇通過隱式轉換增強Scala API的擴充套件，要使用所有可用的擴充套件

#只需為DataSet/DataStrea API新增一個簡單的匯入
DataSet API :
import org.apache.flink.api
 
.scala.extensions._

DataStream API:
import org.apache.flink.streaming.api.scala.extensions._

#Scala Api中經常會在編譯期出現型別的檢查異常,還需要匯入
import org.apache.flink.api.scala._
OR:
import org.apache.flink.api.scala.createTypeInformation

DataSet /D taStream Scala Api 算 子 相關