大数据_Flink_数据处理_流处理API_Source_自定义测试数据源---Flink工作笔记0028

然后我们来看,一般情况下,从文件中读取数据,用的,不如

从kafka,中读取数据用的多.

然后我们再来看一种,自定义数据源,这个主要是我们可以在上线之前模拟很多的数据来进行测试对吧.

这里我们新写一个类

SourceTest4_UDF 这个类