DataStream 编程模型（一） DataSources数据输入_风中云彩的博客

​
        DataSources 模块定义了DataStream API 中的数据输入操作，Flink 将数据源主要分为内置数据源和第三方数据源。其中内置数据源包含文件、Socket网络端口、集合类型数据，不需要引入第三方依赖。第三方数据源定义了数据的读写接口和丰富的第三方数据源连接器。例如Kafka 、Elasticsearch 等。同时用户也可以自定义实现Flink中数据接入函数SourceFuntion,并封装成第三方数据源的connector，完成flink与其他外部系统的数据交互。         DataSources 模块定义了DataStream API 中的数据输