flink

进入主页，点击右上角“设为星标”，这样你就能比别人更快接收到优质文章。 Flink 的容错机制（checkpoint） Flink 的 Checkpoint 容错机制是其可靠性的基石，确保在某个算子因为异常退出等原因故障时，可以将整个应用流图的状态恢复到故障前的某一状态，保证应用流图状态的一致性。F…

在上一篇文章中，我们探讨了flink的时间概念。本文将深入研究flink中的窗口（window）和水位线（watermark）。 窗口（Window） 窗口是处理无界流数据的关键，Flink将无界流分割成多个窗口，并对其生命周期进行了定义： 一个窗口在其第一个元素进入时被创建，当时间（事件时间或处理…

历时一个多月，我们终于结束了【企业级360°全方位用户画像】的项目，想看具体详情的朋友，可以移步至博主的大数据项目专栏一饱眼福… 言归正传，在完成了两个大数据项目之后，接下来的几天，我们将要开始学习一项非常牛X的大数据组件——Flink。相信大数据圈的朋友肯定也早已知晓它的”威力&#82…

不知不觉，这已经是快速入门flink系列的第7篇博客了。早在第4篇博客中，博主就已经为大家介绍了在批处理中，数据输入data sources 与数据输出data sinks的各种分类(传送门:flink批处理的datasources和datasinks)。但是大家是否还记得flink的概念？flin…

apache flink 是一个用于对无界和有界数据流进行状态计算的框架和分布式处理引擎。flink 设计旨在所有常见集群环境中运行，并以内存速度和任意规模进行计算。 为了深入了解 Flink，首先需要搭建其运行环境。 Flink 可以在所有类似 UNIX 的环境中运行，包括 Linux，Mac O…