【Flink】（三）詳解流處理 API(Environment、Source、Transform、Sink)
文章目錄 1、Environment 1.1 getExecutionEnvironment 1.2 createLocalEnvironment 1.3 createRemoteEnvironment 2、Source 2.1 從集合讀取數據 2.2 從文件讀取數據 2.3 以 kafka 消息隊列的數據做爲來源 2.4 自定義 Source 3、轉換算子(Transform) 3.1 map
相關文章
- 1. 1、Stream,sink,source,transform
- 2. Flink流處理-DataStream經常使用Source及Sink
- 3. Flink的流處理API(二)
- 4. Flink之流處理API之Source
- 5. flink自定義source與自定義sink
- 6. flink with rabbitmq,sink source mysql redis es
- 7. flink sql使用kafka做爲source和sink
- 8. Flink 常用的 Source 和 Sink Connectors 介紹
- 9. Flink流處理迭代之化解反饋環
- 10. Flink流處理-HDFS Connector
- 更多相關文章...
- • 錯誤處理 - RUST 教程
- • 免費ARP詳解 - TCP/IP教程
- • Flink 數據傳輸及反壓詳解
- • Java Agent入門實戰（三）-JVM Attach原理與使用
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. 1、Stream,sink,source,transform
- 2. Flink流處理-DataStream經常使用Source及Sink
- 3. Flink的流處理API(二)
- 4. Flink之流處理API之Source
- 5. flink自定義source與自定義sink
- 6. flink with rabbitmq,sink source mysql redis es
- 7. flink sql使用kafka做爲source和sink
- 8. Flink 常用的 Source 和 Sink Connectors 介紹
- 9. Flink流處理迭代之化解反饋環
- 10. Flink流處理-HDFS Connector