Flink的重啟策略 Flink支持不同的重啟策略,這些重啟策略控制著job失敗后如何重啟。集群可以通過默認(rèn)的重啟策略來重啟,這個默認(rè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ù)流的類型一致...