Editor's note: This is the first post in a two-part series about the evo...
投稿
收录了22篇文章 · 13人关注
-
Flink系列-基本概念：Streaming 101: The world beyond batch -
Lightweight Asynchronous Snapshots for Distributed Dataflows(译文)摘要 分布式状态流式处理能够使得持久化计算能够大规模部署到云上进行执行，达到低延迟和高吞吐的目标。不过所面临的最大挑战提供针对潜在失败处理的保证...
-
flink之jobgraph---JobVertex
一。JobVertex 在jobgraph中有一个组成“元素”：JobVertex是不得不提的：jobvertex用于产生intermediat...
-
flink之jobgraph---JobGraph
关于JobGraph的解读 1.在flink里，JobGraph代表一个flink dataflow程序，最终无论是低级的api还是高级的api...
-
关于gobblin应用-mapreduce+azkaban
一。 gobblin部署【mapreduce模式】 1.源码编译：下载源码链接 b。切换到解压文件夹根目录【gradle安装自行参考网上】需要保...
-
HBase内存管理之MemStore
基于跳表实现的MemStore基础模型 实现MemStore模型的数据结构是SkipList（跳表），跳表可以实现高效的查询\插入\删除操作，这...
-
END-TO-END ARGUMENTS IN SYSTEM DESIGN（论文）
This paper presents a design principle that helps guide placement of fun...
-
flink解析之state一。 概述 在流计算场景中，数据没有边界源源不断的流入的，每条数据流入都可能会触发计算，比如在进行count或sum这些操作，是选择每次触发计算...
-
关于checkpoint在flink生产的应用
一.简述 Flink本身为了保证其高可用的特性，以及保证作用的Exactly Once的快速恢复，进而提供了一套强大的checkpoint机制。...
-
Flink中Window/WaterMark/SideOutput的结合使用一.分类 TunbingWindow:滚动窗口 1.前后两个计算不存在重叠 SlidingWindow:滑动窗口 1.元素会在多个窗口中存在,存...
专题公告
关于Apache Flink相关使用
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1736013/u_1015647797_2554199383_fm_26_gp_0.jpg', '推荐专题《Flink实践》（ 分享自 @简书 ）','https://wsa.jianshu.io/c/6a50bd8e1cb6?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','页面编码gb2312|utf-8默认gb2312'));){kind=link}