概述 以Flink算子的視角為入口，解析它們是如何設(shè)計和工作的。 重點在AbstractStreamOperator 實現(xiàn)StreamOpera...
投稿
收錄了10篇文章 · 8人關(guān)注
-
Apache Flink源碼解析 （四）Stream Operator -
[Flink State] 從源碼解析State的保存過程1 前言 State要能發(fā)揮作用，就需要持久化到可靠存儲中，flink中持久化的動作就是checkpointing，那么從TM中執(zhí)行的Task的...
-
Flink 源碼：TM 端恢復(fù)及創(chuàng)建 OperatorState 的流程
本文僅為筆者平日學(xué)習(xí)記錄之用，侵刪原文：https://mp.weixin.qq.com/s/6Oi_1tP-7Jns3ZguMW7wLg 在之...
-
FlinkKafkaConsumer010 代碼閱讀筆記0. FlinkKafkaConsumer010 是 flink 1.6.1 提供的 Kafka 數(shù)據(jù)源接入實現(xiàn)，在 flink 框架中數(shù)據(jù)源需...
-
問題定位：Flink水位線不觸發(fā)問題Flink水位線不觸發(fā)問題 窗口計算時遇到好幾次水位線不觸發(fā)的情況，簡單總結(jié)下。 首先，介紹下Flink的事件時間(EventTime)和水位線...
-
Flink生成Timestamps和Watermarks本章節(jié)是關(guān)于在event time上執(zhí)行的程序。有關(guān)event time, processing time, and ingestion tim...
-
Calcite源碼解析:1.SQL執(zhí)行流程大概流程 一段對SQL執(zhí)行完整的一套代碼。分為四個步驟:總結(jié)來說Calcite有以下主要功能： SQL 解析 SQL 校驗 查詢優(yōu)化 SQL 生...
-
Flink on Yarn模式啟動流程源代碼分析Flink on yarn的啟動流程可以參見前面的文章 Flink on Yarn啟動流程,下面主要是從源碼角度看下這個實現(xiàn)，可能有的地方理解有...
-
Flink on Yarn模式啟動流程分析Flink On Yarn 架構(gòu) 前提條件首先需要配置YARN_CONF_DIR, HADOOP_CONF_DIR ，HADOOP_CONF_P...
-
大數(shù)據(jù)系統(tǒng)的Lambda架構(gòu)Nathan Marz的大作Big Data: Principles and best practices of scalable real-t...
{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/702725/flink.jpg', '推薦專題《Flink深度解析》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/b24167ae1dad?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認gb2312'));){kind=link}