分类： 大数据

Flink系列之二Flink的窗口和水印

通常来讲，Window 就是用来对一个无限的流设置一个有限的集合，在有界的数据集上进行操作的一种机制。window 又可以分为基于时间（Time-based）的 window 以及基于数量（Count-based）的 window。

本文就 Flink 的窗口类型逐一分析，深入理解 fink 的窗口机制以及事件水印在数据流中的作用。

0
1年 ago

Flink系列之一初探flink

Apache Flink 是为分布式、高性能、随时可用以及准确的流处理应用程序打造的开源流处理框架。Flink不仅能同时提供支持高吞吐和严格一次(exactly-once)语义的实时计算，还能提供批量数据处理。

0
1年 ago

CentOS7.2离线安装CDH集群

Cloudera 版本（Cloudera’s Distribution Including Apache Hadoop，简称“CDH”），基于 Web 的用户界面,支持大多数 Hadoop 组件，包括 HDFS、MapReduce、Hive、Pig、 Hbase、Zookeeper、Sqoop，简化了大数据平台的安装、使用难度。

0
1年 ago