https://stackoverflow.com/questions/30699119/what-is-are-the-main-differences-between-flink-and-storm?rq=1 ...
分类：
其他好文 时间：
2017-05-29 12:05:34
阅读次数：
131
dedecms二次开发目录点这个：dedecms二次开发教程目录 字段 类型 整理 属性 Null 默认 额外 id smallint(5) UNSIGNED 是 NULL 友链ID sortrank smallint(6) 是 0 排序值 url char(60) utf8_general_ci ...
分类：
其他好文 时间：
2017-05-17 10:09:17
阅读次数：
146
https://www.iteblog.com/archives/1624.html http://www.infoq.com/cn/news/2015/01/big-data-apache-flink-project http://mp.weixin.qq.com/s?__biz=MzA5Nzkx ...
分类：
其他好文 时间：
2017-05-15 11:14:48
阅读次数：
189
跟传统的关系型数据库类似，Flink提供了优化器“hint”（提示）以告诉优化器选择一些执行策略。目前优化提示主要针对批处理中的连接（join）。在批处理中共有三个跟连接有关的转换函数
分类：
其他好文 时间：
2017-04-26 01:19:51
阅读次数：
262
SlotSharingGroup 表示不同的task可以共享slot，但是这是soft的约束，即也可以不在一个slot 默认情况下，整个StreamGraph都会用一个默认的“default” SlotSharingGroup，即所有的JobVertex的task都可以共用一个slot /** * ... ...
分类：
其他好文 时间：
2017-04-13 12:35:48
阅读次数：
347
1.概述 在大数据的浪潮之下，技术的更新迭代十分频繁。受技术开源的影响，大数据开发者提供了十分丰富的工具。但也因为如此，增加了开发者选择合适工具的难度。在大数据处理一些问题的时候，往往使用的技术是多样化的。这完全取决于业务需求，比如进行批处理的MapReduce，实时流处理的Flink，以及SQL交 ...
分类：
Web程序 时间：
2017-04-09 16:27:41
阅读次数：
321
为最终计划应用范围分区重写Flink的批处理程序允许用户使用partitionByRange API来基于某个（或某些）字段进行按范围分区且可以选择性地指定排序顺序，示例代码如下：
分类：
其他好文 时间：
2017-04-06 14:54:22
阅读次数：
249
submitJob方法分析JobClientActor通过向JobManager的Actor发送SubmitJob消息来提交Job，JobManager接收到消息对象之后，构建一个JobInfo对象以...
分类：
其他好文 时间：
2017-04-03 18:20:09
阅读次数：
317
先看最简单的例子， final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); DataStream> stream = env.addSource(...); stream... ...
分类：
其他好文 时间：
2017-04-01 15:50:14
阅读次数：
414
成本估算在基于成本的优化器中，成本估算非常重要，它直接影响着候选计划的生成。在Flink中成本估算依赖于每个不同的运算符所提供的自己的“预算”，本篇我们将分析什么是成本、运算符如何提供自己的预算以及如...
分类：
其他好文 时间：
2017-03-29 21:18:14
阅读次数：
254
