大数据 - 第 6 页

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-18 输出算子

Flink1.12开始，同样重构了Sink架构

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-17 合流

union

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-16 分流

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-15 物理分区算子

常见的物理分区策略有：随机分配（Random）、轮询分配（Round-Robin）、重缩放（Rescale）和广播（Broadcast）

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-14 用户自定义函数UDF

方式一：匿名实现类方式二：lambda表达式方式三：定义一个类来实现MapFunction 建议单独一个类文件定义类的同时指定初始化参数

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-13 聚合算子

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-12 转换算子

map

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-11 源算子 Source

从Flink1.13开始，主要使用流批统一的新Source架构

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-10 DataStream Api

自定义环境配置

28 9 月

Flink, 大数据

Posted by 蓝染君

flink-09 作业提交模式

Standalone会话模式作业提交流程逻辑流图生成每个算子关系作业流图合并算子链作业流图转换执行流图物理流图就是细化的执行流图逻辑流图（StreamGraph）这是根据用户通过Dat...