Flink的重啟策略 Flink支持不同的重啟策略，這些重啟策略控制著job失敗后如何重啟。集群可以通過默認(rèn)的重啟策略來重啟，這個默認(rèn)的重啟策略...
投稿
收錄了26篇文章 · 94人關(guān)注
Flink的重啟策略 Flink支持不同的重啟策略，這些重啟策略控制著job失敗后如何重啟。集群可以通過默認(rèn)的重啟策略來重啟，這個默認(rèn)的重啟策略...
Flink的并發(fā)執(zhí)行 本章描述如何在Flink中配置程序的并發(fā)執(zhí)行，一個Flink程序可以由不同的task(如:transformations/...
Apache Flink 以一種特有的方式來處理數(shù)據(jù)類型和序列化，包括自有的類型描述器、泛型抽取和類型序列化框架，本文將描述其背后的概念和原理。...
Table API是流處理和批處理通用的關(guān)系型API，Table API可以基于流輸入或者批輸入來運行而不需要進行任何修改。Table API是...
動態(tài)表 這部分即將完成，在此之前請參考: 關(guān)于動態(tài)表介紹的博客****即將完成的是:****Stream->TableTable->Stream...
Table API和SQL通過join API集成在一起，這個join API的核心概念是Table，Table可以作為查詢的輸入和輸出。這篇文...
本頁闡述了使用Flink的API來進行外部數(shù)據(jù)存儲的異步I/O，對于不熟悉異步或者事件驅(qū)動編程的用戶，一篇關(guān)于Future和事件驅(qū)動編程可能會很...
Flink中的每個函數(shù)和算子都可以是有狀態(tài)的(詳情請看Working With State),有狀態(tài)的函數(shù)通過處理各個元素或者事件來存儲數(shù)據(jù)，使...
解析命令行參數(shù)和在Flink應(yīng)用程序中傳遞參數(shù) 幾乎所有的Flink應(yīng)用程序，包括批處理和流處理，都依賴于外部配置參數(shù)，這些參數(shù)被用來指定輸入和...
除了從DataStream操作的結(jié)果中獲取主數(shù)據(jù)流之外，你還可以產(chǎn)生任意數(shù)量額外的側(cè)輸出結(jié)果流。側(cè)輸出結(jié)果流的數(shù)據(jù)類型不需要與主數(shù)據(jù)流的類型一致...
{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/423490/flink-header-logo.png', '推薦專題《Flink文檔翻譯》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/334e4dfdb559?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}