用一个接地气的案例来介绍如何实时计算 UV 数据。大家都知道，在 ToC 的互联网公司，UV 是一个很重要的指标，对于老板、商务、运营的及时决策会产生很大的影响，笔者在电商公司，目前主要的工作就是计算 UV、销售等各类实时数...

很多人不知道什么是Window？有哪些用途？ 下面我们结合一个现实的例子来说明。

Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：十三、min、minBy、max、maxBy函数》cosmozhu写的本系列文章的第十三篇。通过简单的DEMO来演示min、minBy、max、maxBy函数执行的效果 。...

Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：十四、union函数》cosmozhu写的本系列文章的第十四篇。通过简单的DEMO来演示union函数执行的效果 。...

flink join,Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：十五、join函数》cosmozhu写的本系列文章的第十五篇。通过简单的DEMO来演示join函数执行的效果 。...

flink intervalJoin,Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：十六、intervalJoin函数》cosmozhu写的本系列文章的第十六篇。通过简单的DEMO来演示flink intervalJoin函数执行的效...

在上一篇文章Flink-1.9流计算开发：二、Map函数文章中我们使用了map方法。在本篇文章中我们将使用flatMap，来验证一下它与map方法的差异。

整体来讲一个流处理过程可以划分为三部分DataSource、Transformations、Sinks。DataSource用来产生或者获取数据流，Transformations对数据流做转换，Sinks作为数据的出口输出到将数据输出到数据库，文件等系统，不过Transfor...

首先我们需要需要了解的一个概念是Apache Flink支持处理流式计算（stream）和批量计算（batch），但是在目前版本中这两种计算方式各自拥有自己独立的API，本系列文章只讨论流式计算（stream）。...

Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：十二、apply函数》cosmozhu写的本系列文章的第十二篇。通过简单的DEMO来演示apply函数执行的效果 。...