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

做个橙梦

 关注

阅读 68

2022-03-11

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

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

 

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

 

这里我们新写一个类

SourceTest4_UDF 这个类

 

相关推荐

大数据_Flink_数据处理_流处理API_Source_从kafka读取数据---Flink工作笔记0027

青青子衿谈育儿 50 0 0

大数据_Flink_数据处理_流处理API_Source_从文件读取数据---Flink工作笔记0026

吃面多放酱 75 0 0

大数据_Flink_数据处理_流处理API_Source_从集合读取数据---Flink工作笔记0025

guanguans 48 0 0

大数据_Flink_数据处理_流式数据源测试---Flink工作笔记0010

村里搬砖的月野兔 47 0 0

大数据_Flink_数据处理_流处理API_创建执行环境---Flink工作笔记0024

沈芏 51 0 0

大数据_Flink_数据处理_案例WorldCount_流处理版---Flink工作笔记0009

新鲜小饼干 78 0 0

大数据_Flink_数据处理_Flink安装和测试_集群搭建---Flink工作笔记0011

自由的美人鱼 102 0 0

大数据_Flink_数据处理_资源的分配和并行度测试---Flink工作笔记0013

女侠展昭 96 0 0

大数据_Flink_数据处理_Job的提交运行流程---Flink工作笔记0012

zidea 53 0 0

大数据_Flink_Java版_数据处理_流处理API_Flink支持的数据类型---Flink工作笔记0035

扒皮狼 42 0 0

精彩评论（0）

0 0 举报