案例需求：假设用户需要每个1秒钟需要统计4秒钟窗口中数据的量，然后对统计的结果值进行checkpoint处理数据规划使用自定义算子每秒钟产生大约10000条数据产生的数据为一个四元组（Long，String，String，Interger）--（id,name,info,count）数据经统计后，统计结果打印到终端输出打印输出的结果为Long类型的数据开发自定义数据源：代码实现：//**开发自定义数据源//1、自定义样例类caseclassMsg(id:Long,name:String,info:String,cout:Int)//2、自定义数据源，继承RichSourceFunctioncl

案例需求：假设用户需要每个1秒钟需要统计4秒钟窗口中数据的量，然后对统计的结果值进行checkpoint处理数据规划使用自定义算子每秒钟产生大约10000条数据产生的数据为一个四元组（Long，String，String，Interger）--（id,name,info,count）数据经统计后，统计结果打印到终端输出打印输出的结果为Long类型的数据开发自定义数据源：代码实现：//**开发自定义数据源//1、自定义样例类caseclassMsg(id:Long,name:String,info:String,cout:Int)//2、自定义数据源，继承RichSourceFunctioncl