Flink的重啟策略 Flink支持不同的重啟策略兽泣，這些重啟策略控制著job失敗后如何重啟箕憾。集群可以通過默認(rèn)的重啟策略來重啟袍辞，這個(gè)默認(rèn)的重啟策略...

Flink的并發(fā)執(zhí)行 本章描述如何在Flink中配置程序的并發(fā)執(zhí)行浆兰，一個(gè)Flink程序可以由不同的task(如:transformations/...

Apache Flink 以一種特有的方式來處理數(shù)據(jù)類型和序列化，包括自有的類型描述器家妆、泛型抽取和類型序列化框架鸵荠，本文將描述其背后的概念和原理。...

Table API是流處理和批處理通用的關(guān)系型API伤极，Table API可以基于流輸入或者批輸入來運(yùn)行而不需要進(jìn)行任何修改蛹找。Table API是...

動(dòng)態(tài)表 這部分即將完成，在此之前請(qǐng)參考: 關(guān)于動(dòng)態(tài)表介紹的博客****即將完成的是:****Stream->TableTable->Stream...

Table API和SQL通過join API集成在一起哨坪，這個(gè)join API的核心概念是Table庸疾，Table可以作為查詢的輸入和輸出。這篇文...

本頁闡述了使用Flink的API來進(jìn)行外部數(shù)據(jù)存儲(chǔ)的異步I/O当编，對(duì)于不熟悉異步或者事件驅(qū)動(dòng)編程的用戶届慈，一篇關(guān)于Future和事件驅(qū)動(dòng)編程可能會(huì)很...

Flink中的每個(gè)函數(shù)和算子都可以是有狀態(tài)的(詳情請(qǐng)看Working With State),有狀態(tài)的函數(shù)通過處理各個(gè)元素或者事件來存儲(chǔ)數(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ù)流的類型一致...