DataStream
DataStream API（一）
DataStream API（一） Flink 有非常灵活的分层 API 设计，其中的核心层就是 DataStream/DataSet API。由于新版 本已经实现了流批一体， DataSet API 将被弃用，官方推荐统一使用 DataStream API 处理流数 据和批数据。由于内容较多，我们 ......
DataStream（二）
DataStream（二） 目录 5.3.2 聚合算子（Aggregation） 5.3.3 用户自定义函数（UDF） 3. 扁平映射（flatMap） flatMap 操作又称为扁平映射，主要是将数据流中的整体（一般是集合类型）拆分成一个 一个的个体使用。消费一个元素，可以产生 0 到多个元素。f ......
Flin(二)：DataStream API_算子
一、流元素 Flink的DataStream Api 支持的流元素： 1、基本类型：例如字符串、整型、布尔型、数组等； 2、Java元组和POJO类型 3、Scala元素组和case类； 二、执行环境 每个Flink应用需要一个执行环境，流处理应用需要StreamExecutionEnvironme ......
Flink DataStream API
Flink 的 DataSet 和 DataStream 的 API，并模拟了实时计算的场景。 说好的流批一体呢 现状 Flink 很重要的一个特点是“流批一体”，然而事实上 Flink 并没有完全做到所谓的“流批一体”，即编写一套代码，可以同时支持流式计算场景和批量计算的场景。目前截止 1.10 ......
Flink核心API之DataStream
 Flink中提供了4种不同层次的API，每种API在简洁和易表达之间有自己的权衡，适用于不同的场景。目前 ......