Flink在流上最大的特点，就是引入全局snapshot， CheckpointCoordinator 做snapshot的核心组件为， CheckpointCoordinator CheckpointIDCounter 有两种， StandaloneCheckpointIDCounter 这种ca ...
分类：
其他好文 时间：
2016-11-19 03:36:53
阅读次数：
203
CheckpointBarrierHandler 这个接口用于react从input channel过来的checkpoint barrier，这里可以通过不同的实现来，决定是简单的track barriers，还是要去真正的block inputs BarrierBuffer 最关键的函数， 其中 ...
分类：
其他好文 时间：
2016-11-19 03:35:40
阅读次数：
179
Metrics是以MetricsGroup来组织的 MetricGroup MetricGroup 这就是个metric容器，里面可以放subGroup，或者各种metric 所以主要的接口就是注册， /** * A MetricGroup is a named container for {@li... ...
分类：
其他好文 时间：
2016-11-10 16:50:13
阅读次数：
325
窗口算子WindowOperator是窗口机制的底层实现，它几乎会牵扯到所有窗口相关的知识点，因此相对复杂。本文将以由面及点的方式来分析WindowOperator的实现。
分类：
其他好文 时间：
2016-11-05 09:46:22
阅读次数：
267
标记名称：flink [标签简介] [功能说明]：用于获取友情链接,其对应后台文件为"includetaglibflink.lib.php". [适用范围]：全局标记，适用V55,V56,V57。 [参数说明]： [1]type：链接类型，值： a. textall 全部用文字显示; b. text ...
分类：
其他好文 时间：
2016-10-29 18:58:18
阅读次数：
204
https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals FLIP-1 : Fine Grained Recovery from Task Failures When a task fails duri... ...
分类：
其他好文 时间：
2016-10-13 14:17:30
阅读次数：
322
参考资料： drill 官网：http://drill.apache.org/ drill安装使用：https://segmentfault.com/a/1190000002652348 drill简介：http://www.csdn.net/article/2012-08-20/2808871 S ...
分类：
其他好文 时间：
2016-09-22 10:12:35
阅读次数：
196
大数据通用处理平台 Spark Flink Hadoop 分布式存储 HDFS 资源调度 Yarn Mesos 机器学习工具 Mahout Spark Mlib TensorFlow (Google 系) Amazon Machine Learning DMTK (微软分布式机器学习工具) 数据分析 ...
分类：
其他好文 时间：
2016-09-08 23:05:28
阅读次数：
188
一：网站要支持申请友链 url:/plus/flink_add.php =——————————————————–利用开始————————– 直接填写验证码，抓包 修改POST数据 写人exp: 1 Submit=%20%E6%8F%90%20%E4%BA%A4%20&dopost=save&emai ...
分类：
数据库 时间：
2016-09-03 21:03:37
阅读次数：
636
Savepoint 本文翻译自文档Streaming Guide / Savepoints 使用DataStream API编写的程序可以从一个savepoint处恢复执行。savepoint可以同时更新你的程序和Flink集群而不丢失任何状态。该文档包括了从触发、存储以及销毁(dispose)sa ...
分类：
编程语言 时间：
2016-08-19 20:34:30
阅读次数：
276
