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 一共 ...