Flink应用开发系列（二十六）DataStream开发之自定义source

在flink datastream中进行应用开发的时候，除了使用系统自带的source之外，我们还可以自定义source，然后使用StreamExecutionEnvironment.addSource(sourceFunction)的方式添加自定义的source数据源。在之前的文章中，其实我们已经介绍过了如何实现一个自定义的source，详情可参考本文《Flink学习系列（四）flink的datasource之自定义mysql的connector》。