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 （6） -- 窗口 （DataStream API编程指导 -- For Java）
窗口 Window 本文翻译自文档Windows Flink使用窗口的概念，根据element的时间戳或者其他指标，将可能无限的DataStream分割为有限的数据切片 slice 。我们在处理无限数据流以及进行聚合element的transformation时需要此种窗口分割。 注意：我们在此文档中讨论的大多是keyed windowing，即window是应用在KeyedStream上的。关键 ...
2016-08-16 00:15 0 1550 推荐指数：
相关推荐
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提 ...
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 Program Guide （9） -- StateBackend : Fault Tolerance（Basic API Concepts -- For Java）
State Backends 本文翻译自文档Streaming Guide / Fault Tolerance / StateBackend ...
Flink DataStream API
1. API基本概念 Flink程序可以对分布式集合进行转换（例如： filtering, mapping, updating state, joining, grouping, defining windows, aggregating） 集合最初是从源创建的（例如，从文件、kafka主题 ...
Flink （三）DataStream API
第五章 DataStream API Flink有非常灵活的分层 API设计，其中的核心层就是 DataStream/DataSet API。由于新版本已经实现了流批一体， DataSet API将被弃用，官方推荐统一使用 DataStream API处理流数据和批数据。由于内容较多，我们将会 ...
Flink 编程接口（Flink SQL Table API DataStream API 和 DataSet API Stateful Stream Process API）
Flink 根据数据集类型的不同将核心数据处理接口分为两大类，一类是支持批计算的接口DataSet API，另外一类是支持流计算的接口 DataStream API。同时 Flink将数据处理接口抽象成四层，由上向下分别为SQL API、Table API、DataStream /DataSet ...