Flink Program Guide （2） -- 綜述 （DataStream API編程指導 -- For Java）
v\:* {behavior:url(#default#VML);} o\:* {behavior:url(#default#VML);} w\:* {behavior:url(#defau ...
原文：Flink Program Guide （9） -- StateBackend : Fault Tolerance（Basic API Concepts -- For Java）
State Backends 本文翻譯自文檔Streaming Guide Fault Tolerance StateBackend 使用Data Stream API編寫的程序通常以多種形式維護狀態： 窗口將收集element或在它被觸發后聚合element Transformation方法可能會使用key value狀態接口來存儲值 Transformation方法也可能會實現Checkpoi ...
2016-08-19 00:05 0 1656 推薦指數：
相關推薦
Flink Program Guide （6） -- 窗口 （DataStream API編程指導 -- For Java）
窗口（Window） 本文翻譯自文檔Windows ----------------------------------- Flink使用窗口的概念，根據element的時間戳或者其他指標，將可能無限的DataStream分割為有限的數據切片(slice)。我們在處理無限 ...
Flink Program Guide （4） -- 時間戳和Watermark生成（DataStream API編程指導 -- For Java）
時間戳和Watermark生成 本文翻譯自Generating Timestamp / Watermarks ------------------------------------------------------------------ 本文是Flink在使用事件時間 ...
Flink Program Guide （5） -- 預定義的Timestamp Extractor / Watermark Emitter （DataStream API編程指導 -- For Java）
------------------------------------------------------------------------------------------ 正如timestamps and watermark handling中所述，Flink提 ...
容錯(Fault-tolerance)
Spark Streaming的容錯包括了三個地方的容錯： 1、Executor失敗容錯：Executor的失敗會重新啟動一個新的Executor，這個是Spark自身的特性。如果Rece ...
Flink DataSet API Programming Guide
https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/programming_guide.html Example Program 編程的風格和spark很類似， ExecutionEnvironment ...
Flink DataStream API Programming Guide
Example Program The following program is a complete, working example of streaming window word count application, that counts the words coming from ...
Flink StateBackend 狀態后端
一、概述 保存機制 StateBackend ，默認情況下，State 會保存在 TaskManager 的內存中，CheckPoint 會存儲在 JobManager 的內存中。 State 和 CheckPoint 的存儲位置取決於 StateBackend 的配置。 Flink 一共 ...