Flink中的数据交换构建在如下两条设计原则之上：
数据交换的控制流（例如，为实例化交换而进行的消息传输）是接收端初始化的，这非常像最初的MapReduce。
数据交换的数据流（例如，在网络上最终传输的数据）被抽象成一个叫做IntermediateResult的概念，它是可插拔的。这意味着系统基于相同的实现逻辑可以既支持流数据，又支持批处理数据的传输。...
分类：
其他好文 时间：
2016-04-29 18:48:07
阅读次数：
189
Flink中的数据交换构建在如下两条设计原则之上：
数据交换的控制流（例如，为实例化交换而进行的消息传输）是接收端初始化的，这非常像最初的MapReduce。
数据交换的数据流（例如，在网络上最终传输的数据）被抽象成一个叫做IntermediateResult的概念，它是可插拔的。这意味着系统基于相同的实现逻辑可以既支持流数据，又支持批处理数据的传输。...
分类：
其他好文 时间：
2016-04-26 21:00:48
阅读次数：
395
Example Program The following program is a complete, working example of streaming window word count application, that counts the words coming from a w... ...
经常有人会问Flink如何处理背压问题。其实，答案很简单：Flink没用使用任何通用方案来解决这个问题，因为那根本不需要那样的方案。它利用自身作为一个纯数据流引擎的优势来优雅地响应背压问题。...
分类：
其他好文 时间：
2016-04-22 19:22:44
阅读次数：
200
https://flink.apache.org/news/2015/09/16/off-heap-memory.html Running data-intensive code in the JVM and making it well-behaved is tricky. Systems tha... ...
分类：
Web程序 时间：
2016-04-08 12:03:55
阅读次数：
303
回顾上一篇文章我们谈了Flink自主内存管理的一些基础的数据结构。那篇中主要讲了数据结构的定义，这篇我们来看看那些数据结构的使用，以及内存的管理设计。概述这篇文章我们主要探讨Flink的内存管理类MemoryManager涉及到对内存的分配、回收，以及针对预分配内存而提供的memory segment pool。还有支持跨越多个memory segment数据访问的page view。...
分类：
其他好文 时间：
2016-04-07 07:14:45
阅读次数：
288
启动关闭bin/start-cluster.shbin/stop-cluster.sh 最后上架构图和执行流程图，看起来和spark很类似 ...
分类：
Web程序 时间：
2016-04-02 14:49:45
阅读次数：
501
http://www.36dsj.com/archives/33650 http://flink.apache.org/news/2015/05/11/Juggling-with-Bits-and-Bytes.html http://www.bigsynapse.com/addressing-big... ...
分类：
其他好文 时间：
2016-03-29 21:27:49
阅读次数：
335
概述在分布式实时计算领域，如何让框架/引擎足够高效地在内存中存取、处理海量数据是一个非常棘手的问题。在应对这一问题上Flink无疑是做得非常杰出的，Flink的自主内存管理设计也许比它自身的知名度更高一些。正好最近在研读Flink的源码，所以开两篇文章来谈谈Flink的内存管理设计。...
分类：
其他好文 时间：
2016-03-26 07:53:27
阅读次数：
239
https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/programming_guide.html Example Program 编程的风格和spark很类似， ExecutionEnvironment -- Spark...
