【05 计算平台 蓉荣】Flink 批处理及其应⽤Flink 批处理理及其应⽤用 What is Apache Flink * Apache Flink 是⼀一个分布式⼤大数据处理理引擎 * 可对有限数据流和⽆无限数据流进⾏行行有状态计算 * 可部署在各种集群环境 * 对各种⼤大⼩小的数据规模进⾏行行快速计算 为什什么Flink能做批处理理 Table Stream Bounded Data Unbounded Data0 码力 | 12 页 | 1.44 MB | 1 年前3
Apache Flink的过去、现在和未来丰富的 State API。 ValueState, ListState, MapState BroadcastState。 支持基于事件时间的计 算,实现 Watermark 机 制。乱序数据处理,迟 到数据容忍。 开箱即用的滚动、滑 动、会话窗口。以及 灵活的自定义窗口。 State Time Window 2015 年阿里巴巴开始使用 Flink 并持续贡献社区 重构分布式架构0 码力 | 33 页 | 3.36 MB | 1 年前3
Flink如何实时分析Iceberg数据湖的CDC数据写5oFitioA ,elete FileM否则直接a,elete行写 -DualitJ delete fileO 写T思l 1N5oFitioA ,elete File和nR SeD3umP大Qi己SeD3um 的,ata FileS 04I3M 2N-DualitJ ,elete File和n RSeD3um小Qi己SeD3um 的,ata FileS 04I3O 读取思l *CClJ0 码力 | 36 页 | 781.69 KB | 1 年前3
共 3 条
- 1













