“ 一切都会过去!除了羊的第二关....” 今天,你“羊”了吗?这应该是最近出现频次最多的用语了吧!“羊了个羊”是最近非常火爆的一款微信小游戏。...
前言 我们知道,Flink 程序的执行是在我们调用 env.execute() 后才会真正开始。事实上,我们在编写业务代码时,是在勾勒程序执行的...
回顾 Flink 因其高吞吐、低延时、有状态、高容错的特性越来越受到数据从业者的青睐,它弥补了Storm、Spark 的很多不足。作为一个实时计...
回顾 在之前的学习中我们了解到,flink 作为低延时的流式数据处理框架,本身是有状态的。状态 state 是为了保存一些操作符 operato...
数据仓库介绍 数据仓库是集成的、面向主题的、反应历史的数据的集合。它需要具有高效查询、高质量的、可扩展的的特性。数据仓库是协助运营及管理人员及时...
flink 回顾 通过之前的了解,我们知道,flink是一个高吞吐、低延时的流式处理框架。flink 中具有严格的时间定义,采用不同的时间机制,...
flink 抽象分层结构 flink 作为流式处理框架,不仅具有高效的流数据和批数据处理性能,具有针对开发人员使用的高效的底层API,同时有方便...
Apache flink 简介 Apache flink 是分布式流式数据处理框架,主要用于有界(bounded)和无界(unbounded)数...
flink Sink简介 flink 中有两个重要的概念,Source 和 Sink ,Source 决定了我们的数据从哪里产生,而 Sink ...