VIP20
本课程属于：063-信用额度定价人群切片复盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink额度实时计算入门教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
Flink概述
Flink的发展历史 · 核心特性 · 应用场景（实时ETL
Flink的发展历史
02
Flink环境搭建
本地模式（Standalone） · YARN模式 · Kubernetes模式的安装与配置
Flink环境搭建
03
Flink编程模型
DataStream API与Dat… · Flink程序的基本骨架（Sourc… · Transformation
Flink编程模型
04
Flink DataStream入门
第一个Flink流处理程序（Word… · 理解并行度 · Task与SubTask的概念
FlinkDataStream
05
Flink Source
内置Source（文件 · Socket · 集合
FlinkSource
06
Flink Transformation（一）
map · flatMap · filter
FlinkTransformati…
07
Flink Transformation（二）
union · connect · coMap
FlinkTransformati…
08
Flink Sink
内置Sink（Kafka · Elasticsearch · JDBC
FlinkSink
09
Flink时间语义
Event Time · Ingestion Time · Processing Time的区别…
Flink时间语义
10
Flink Watermark
Watermark的原理 · 生成策略（周期性 · 标点式）
FlinkWatermark
11
Flink Window（一）
滚动窗口（Tumbling Wind… · 滑动窗口（Sliding Windo… · 会话窗口（Session Windo…
FlinkWindow
12
Flink Window（二）
窗口函数（ReduceFunctio… · AggregateFunction · ProcessWindowFunct…
FlinkWindow
13
Flink状态管理
Keyed State与Operat… · ValueState · ListState
Flink状态管理
14
Flink状态后端
MemoryStateBackend · FsStateBackend · RocksDBStateBacken…
Flink状态后端
15
Flink Checkpoint与Savepoint
Checkpoint原理 · 配置 · Exactly-Once语义
FlinkCheckpoint
16
Flink容错机制
重启策略（固定延迟 · 失败率 · 无重启）
Flink容错机制
17
Flink与Kafka集成
Kafka Source与Sink的… · Kafka消息的序列化与反序列化 · 在实时额度流中的上下游对接
FlinkKafka
18
Flink SQL入门
Table API与SQL的基本使用 · 动态表的理解 · 在额度计算中简化开发
FlinkSQL
19
Flink SQL窗口与聚合
SQL中的滚动窗口 · 滑动窗口 · Group By聚合
FlinkSQL
20
Flink SQL与Kafka连接
使用DDL创建Kafka表 · 实现流表关联（Stream-Tabl… · 实时额度宽表构建
FlinkSQL
21
Flink CEP（复杂事件处理）
Pattern API的定义 · 匹配额度超限 · 连续异常交易等复杂事件序列
FlinkCEP
22
Flink CEP实战
在额度计算中检测“小额试探+大额盗刷… · 输出告警
FlinkCEP
23
Flink ProcessFunction
KeyedProcessFuncti… · ProcessFunction的定时… · 实现额度到期自动重置
FlinkProcessFunct…
24
Flink广播状态（Broadcast State）
动态加载额度规则（如黑名单 · 费率表） · 实现规则热更新
FlinkBroadcast
25
Flink双流Join
Window Join · Interval Join · Regular Join的原理与实现
FlinkJoin
26
Flink异步IO（Async I/O）
AsyncDataStream的使用 · 在额度计算中异步查询外部Redis/… · 提升吞吐
FlinkIO
27
Flink内存管理与调优
内存模型 · 网络缓冲区 · 堆外内存配置
Flink内存管理
28
Flink反压（Backpressure）机制
反压的原理 · 监控（Web UI指标） · 定位与解决方案（调整并行度
FlinkBackpressure
29
Flink额度实时计算项目实战（一）
需求分析 · 架构设计（数据源 · 计算层
Flink额度实时计算项目…
30
Flink额度实时计算项目实战（二）
代码实现（额度初始化 · 消费Kafka · 窗口聚合
Flink额度实时计算项目…