欢迎访问我的GitHubhttps://github.com/zq2599/blog\_demos(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fgithub.com%2Fzq2599%2Fblog_demos)内容：所有原创文章分类汇总及配套源码，涉及Java、Doc

\resourcejar\_pathclazzjobNamebootstrap\_servertopicgroupIdisSecuritytrueconsumerStrategyredis\_hostnameredis\_portif\"$isSecu

process算子：处理每个keyBy（分区）输入到窗口的批量数据流（为KeyedStream类型数据流）示例环境java.version:1.8.xflink.version:1.11.1示例数据源（项目码云下载）Flink系例之搭建开发环境与数据(https://my.oschina.net/u/43

maxBy聚合：获取一组数据流算子中最大的记录行（和max的区别，max是返回计算字段的最大值）示例环境java.version:1.8.xflink.version:1.11.1 示例数据源（项目码云下载）Flink系例之搭建开发环境与数据(https://my.oschina.net/u/437309

欢迎访问我的GitHubhttps://github.com/zq2599/blog\_demos内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等；本文是《FlinkonYarn三部曲》系列的终篇，先简单回顾前面的内容：1.《FlinkonYarn三部曲之一：准备工作》

!(https://oscimg.oschina.net/oscnet/bef571d44e3a4e089a93cde787fecb99.gif)和其他所有的计算框架一样，flink也有一些基础的开发步骤以及基础，核心的API，从开发步骤的角度来讲，主要分为四大部分!(https://oscimg.oschina.net/oscnet

!(https://oscimg.oschina.net/oscnet/26be8681c4f5ef263dedfec3b0af7133f9b.jpg)(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fmp.weixin.qq.com%2Fs%3F__biz%3DMzU3MzgwNT

!(https://imgblog.csdnimg.cn/img_convert/c855753e7a5823566762bba3680fa336.png)​往期推荐：Flink基础：入门介绍(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fmp.weixin.q

一，抽象层次Flink提供不同级别的抽象来开发流/批处理应用程序。!(https://oscimg.oschina.net/oscnet/12b00149837444cda182f2b438ddd72a.png)1，statefulstreaming最底层。它通过ProcessFunction嵌入到DataSt

_摘要：_ 实际问题我们知道在流计算场景中，数据是源源不断的流入的，数据流永远不会结束，那么计算就永远不会结束，如果计算永远不会结束的话，那么计算结果何时输出呢？本篇将介绍ApacheFlink利用持续查询来对流计算结果进行持续输出的实现原理。实际问题我们知道在流计算场景中，数据是源源不断的流入的，数据流永远不会结束，那么计算就永远不会