Flink學習筆記(3) -- Flink API解析

1、Flink DataStreamAPI Ⅰ、DataStream API 之 Data Sources部分詳解   source是程序的數據源輸入,你可以通過StreamExecutionEnvironment.addSource(sourceFunction)來爲你的程序添加一個source。   flink提供了大量的已經實現好的source方法,你也可以自定義source   通過實現s
相關文章
相關標籤/搜索