Flink-org.apache.flink.api.common.functions.AggregateFunction

该接口的注释上有很明白的代码例子在里面，本文只是简单的记录一下并且加上个人对这个接口的理解与不解，该签名如下

AggregateFunction<IN, ACC, OUT>

泛型IN指的是输入
泛型OUT指的是输出
泛型ACC叫累加器，指的是在一个窗口周期内一直存活的一个对象，该对象是让我们对每一个过来的数据进行累加并且保存其结果的

// 每次开始统计一个窗口内的数据的时候，就会调用一次该方法
ACC createAccumulator();
// 每次来数据的时候，都会调用一次该方法
// 假设在一个窗口周期之内来了三次数据，那么就会调用三次该方法
ACC add(IN value, ACC accumulator);
// 在getResult之前会调用一次这个方法，将多个slot中的ACC相加到一起，
// 准备用来统计
ACC merge(ACC a, ACC b);
// 每次即将统计的时候，调用该方法，因为该方法就是用来统计
OUT getResult(ACC accumulator);

Flink-org.apache.flink.api.common.functions.AggregateFunction相关推荐

《从0到1学习Flink》—— Apache Flink 介绍
前言 Flink 是一种流式计算框架,为什么我会接触到 Flink 呢?因为我目前在负责的是监控平台的告警部分,负责采集到的监控数据会直接往 kafka 里塞,然后告警这边需要从 kafka topi ...
【Flink】Apache Flink 1.13.0 正式发布，流处理应用更加简单高效
1.概述转载:Apache Flink 1.13.0 正式发布,流处理应用更加简单高效侵权可删,这里是做个笔记,防止找不到. Flink 1.13 发布了!Flink 1.13 包括了超过 200 ...
Flink java.lang.NoClassDefFoundError: org/apache/flink/api/common/functions/FlatMapFunction
【云星数据---Apache Flink实战系列(精品版)】：Apache Flink批处理API详解与编程实战025--DateSet实用API详解025
一.Flink DateSet定制API详解(JAVA版) -002 flatMap 以element为粒度,对element进行1:n的转化. 执行程序: package code.book.bat ...
Apache Flink介绍、架构、原理以及实现
文章目录一 Flink简介 1.1 什么是flink 1.2 flink的特点 1.3 编程API 二 Flink架构 2.1 架构图 2.2 运行组件 2.3 关键词含义三 Flink原理 3. ...
Apache Flink 简介和编程模型
Apache Flink是一个同时支持分布式数据流处理和数据批处理的大数据处理系统. Flink可以表达和执行许多类别的数据处理应用程序,包括实时数据分析,连续数据管道,历史数据处理(批处理)和迭代算 ...
1.11.Flink DataSetAPI、DataSet API之Data Sources、DataSet API之Transformations、DataSet Sink部分详解
1.11.Flink DataSetAPI 1.11.1.DataSet API之Data Sources 1.11.2.DataSet API之Transformations 1.11.3.Data ...
Apache Flink 读取本地文件，处理数据，导入ES
需求本地有一份文件使用Flink读取本地数据源处理数据,导入ES中提交Flink作业环境 Flink :1.8.2 Elasticsearch:6.2.3 JDK:1.8 pom.xml & ...
5分钟从零构建第一个 Apache Flink 应用
为什么80%的码农都做不了架构师?>>> 在本文中,我们将从零开始,教您如何构建第一个Apache Flink (以下简称Flink)应用程序. 开发环境准备 Flink 可以 ...

Flink-org.apache.flink.api.common.functions.AggregateFunction

Flink-org.apache.flink.api.common.functions.AggregateFunction相关推荐

最新文章

热门文章