Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:八、time-window-tumbling窗口函数》是cosmozhu写的本系列文章的第八篇。
accumulator; } }) .print(); env.execute(Flink Streaming Java API Skeleton); }}执行效果4> {苹果2, 葡萄1, 火龙果2, 梨
2, 西瓜2}1> {火龙果2, 梨2, 西瓜6}2> {火龙果1, 梨3, 西瓜6}3> {葡萄1, 苹果3, 梨2, 西瓜4}小结这里解释一下tumbling这个窗口,如图所示
github.comchaoxxxlearn-flink-stream-apiblobmastersrcmainjavafuncosmozhusession8StreamTest.java----作者:cosmozhu --90后的老父亲,专注于保护地球的程序员 个人网站
相关文章 Flink-1.9流计算开发:十六、intervalJoin函数 Flink-1.9流计算开发:十五、join函数 Flink-1.9流计算开发:十四、union函数 Flink-1.9流计算开发