Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:六、reduce函数》是cosmozhu写的本系列文章的第六篇。
value1.f1+value2.f1); } }) .print(); env.execute(Flink Streaming Java API Skeleton); }}执行效果3> (西瓜,1)3> (梨,
1)3> (苹果,1)2> (火龙果,1)3> (梨,2)3> (梨,3)3> (苹果,2)3> (梨,4)1> (葡萄,1)小结这里利用reduce函数实现了与sum函数相同的效果。
github.comchaoxxxlearn-flink-stream-apiblobmastersrcmainjavafuncosmozhusession6StreamTest.java----作者:cosmozhu --90后的老父亲,专注于保护地球的程序员 个人网站
相关文章 Flink-1.9流计算开发:十六、intervalJoin函数 Flink-1.9流计算开发:十五、join函数 Flink-1.9流计算开发:十四、union函数 Flink-1.9流计算开发