官术网_书友最值得收藏!

3.2 Flink支持的數據源

數據源是Flink程序希望從其中獲取數據的地方。可以從多個源創建數據集,如Apache Kafka、CSV、文件或幾乎任何其他數據源。Flink附帶了許多預先實現的數據源函數。它還支持編寫自定義數據源函數。

首先理解Flink內置的數據源函數??梢詮腟treamExecutionEnvironment訪問預定義的數據源。

注意:在實際應用程序中,最常用的數據源是那些支持低時延、高吞吐量并行讀取及重放和rewind的數據源,這是實現高性能和容錯的先決條件,例如Apache Kafka、Kinesis和各種文件系統。

主站蜘蛛池模板: 庆阳市| 堆龙德庆县| 天柱县| 华阴市| 榆中县| 饶平县| 镇安县| 西平县| 始兴县| 太康县| 诏安县| 伊金霍洛旗| 东乡县| 高唐县| 株洲县| 定结县| 商水县| 泰来县| 高要市| 阿拉善盟| 三都| 沭阳县| 梧州市| 西乡县| 乌拉特后旗| 大埔县| 石河子市| 广东省| 大渡口区| 娱乐| 洪洞县| 夏津县| 松溪县| 疏附县| 北票市| 那曲县| 库尔勒市| 广宗县| 微博| 巨野县| 博爱县|