阶段掌握：0%
|
课程：0/171 |
0/171 掌握点
关于本阶段
新一代流批一体计算框架。核心特性：
-精确一次（Exactly-Once）状态一致性
-事件时间（Event Time）处理与水位线（Watermark）
-状态后端（State Backend）：Memory/RocksDB
-应用场景：实时ETL、风控预警、CEP复杂事件处理。
学习
-
7-1 Flink-Partitioner算子之GlobalPartitioner
-
7-2 Flink-Partitioner算子之RebalancePartitioner
-
7-3 Flink-Partitioner算子之RescalePartitioner
-
7-4 Flink-Partitioner算子之ShufflePartitioner
-
7-5 Flink-Partitioner算子之BroadcastPartitioner
-
7-6 Flink-Partitioner算子之ForwardPartitioner
-
7-7 Flink-Partitioner算子之KeyGroupStreamPartitioner
-
7-8 Flink-Partitioner算子之CustomPartitioner
-
7-9 Flink-Partitioner算子之总结
练习
学习
-
9-1 Flink-时间语义的概念
-
9-2 Flink-时间语义的代码实现
-
9-3 Flink-窗口函数的定义
-
9-4 Flink-CountWindow分类之滚动与滑动
-
9-5 Flink-CountWindow分类之代码实现
-
9-6 Flink-CountWindowAll分类与代码实现
-
9-7 Flink-TimeWindow之ProcessTime和Keyed条件下的滚动与滑动
-
9-8 Flink-TimeWindow之ProcessTime和Keyed条件下的会话
-
9-9 Flink-TimeWindow之ProcessTime和NoKeyed条件下的WindowAll
-
9-10 Flink-GlobalWindow的定义和使用
-
9-11 Flink-WindowFunctions的概念与分类
-
9-12 Flink-WindowFunctions增量函数之Reduce
-
9-13 Flink-WindowFunctions增量函数之Aggregate
-
9-14 Flink-WindowFunctions全量函数之Window
练习
学习
-
10-1 Flink-WaterMark的意义
-
10-2 Flink-WaterMark的分类之有序和无序
-
10-3 Flink-WaterMark的分类之拯救大兵瑞恩
-
10-4 Flink-WaterMark的有序数据水位线生成
-
10-5 Flink-WaterMark的无序数据水位线生成
-
10-6 Flink-WaterMark的自定义周期型有序水位线
-
10-7 Flink-WaterMark的自定义周期型无序水位线
-
10-8 Flink-WaterMark的自定义定点型无序水位线
-
10-9 Flink-WaterMark的迟到数据的解决方案
-
10-10 Flink-WaterMark的迟到数据的代码实现
练习
学习
-
14-1 Flink-EOS之分布式集群状态一致性问题
-
14-2 Flink-EOS之事件处理语义的四种一致性级别
-
14-3 Flink-EOS之Chandy-Lamport算法核心思想
-
14-4 Flink-EOS之Flink的检查点存储思想
-
14-5 Flink-EOS之Barrier的意义和作用
-
14-6 Flink-EOS之从四大名著到Barrier对齐
-
14-7 Flink-EOS之CheckPoint流程详解
-
14-8 Flink-EOS之Barrier对不齐
-
14-9 Flink-EOS之SavePoint
-
14-10 Flink-EOS之容错策略
-
14-11 Flink-EOS之端到端STS的Source
-
14-12 Flink-EOS之端到端STS的Transformation
-
14-13 Flink-EOS之端到端STS的Sinkの幂等和事务
-
14-14 Flink-EOS之端到端STS的Sinkの两阶段提交
练习
学习
-
21-1 Flink-FlinkSQL表结构篇之ConnectorUseJDBC
-
21-2 Flink-FlinkSQL表结构篇之ConnectorUseDataGen
-
21-3 Flink-FlinkSQL表结构篇之ConnectorUseUpsertKafka
-
21-4 Flink-FlinkSQL表结构篇之ConnectorUseFileSystem
-
21-5 Flink-FlinkSQL表结构篇之Schema
-
21-6 Flink-FlinkSQL表结构篇之Format
-
21-7 Flink-FlinkSQL表结构篇之Watermark概念动态表与连续查询
-
21-8 Flink-FlinkSQL表结构篇之Watermark之处理时间
-
21-9 Flink-FlinkSQL表结构篇之Watermark之事件时间
-
21-10 Flink-FlinkSQL表结构篇之Watermark之时间语义
-
21-11 Flink-FlinkSQL表结构篇之TVF之Tumble
-
21-12 Flink-FlinkSQL表结构篇之TVF之Hop
-
21-13 Flink-FlinkSQL表结构篇之TVF之Cumulate
-
21-14 Flink-FlinkSQL表结构篇之TVF之Offset
练习
学习
-
22-1 Flink-FlinkSQL查询篇之分组聚合distinct
-
22-2 Flink-FlinkSQL查询篇之分组聚合groupsetrollupcube
-
22-3 Flink-FlinkSQL查询篇之窗口聚合
-
22-4 Flink-FlinkSQL查询篇之开窗聚合
-
22-5 Flink-FlinkSQL查询篇之TopN
-
22-6 Flink-FlinkSQL查询篇之TopNForWindow
-
22-7 Flink-FlinkSQL查询篇之RegularJoin
-
22-8 Flink-FlinkSQL查询篇之IntervalJoin
-
22-9 Flink-FlinkSQL查询篇之TemporalJoin
-
22-10 Flink-FlinkSQL查询篇之SQLClient
-
22-11 Flink-FlinkSQL查询篇之TableAPI官方文档
-
22-12 Flink-FlinkSQL查询篇之SQL官方文档