VIP20
本课程属于：034-高频行情数据规则灰度发布 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

高频行情灰度发布与Flink实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
高频行情概述
高频行情的定义 · 特点 · 数据源（交易所Level-1/Lev…
高频行情概述高频行情的定义
02
灰度发布基础
灰度发布的概念 · 目的 · 策略（金丝雀发布
灰度发布基础灰度发布的概念
03
Flink核心概念
Flink简介 · DataStream API · 事件时间与处理时间
Flink核心概念
04
Flink环境搭建
Flink单机与集群模式部署 · Flink on YARN/K8s配… · 开发环境（IDEA + Maven）…
Flink环境搭建
05
Flink DataStream API入门
Source（Kafka · Socket） · Transformation（map
FlinkDataStream
06
Flink时间语义与Watermark
事件时间与处理时间对比 · Watermark生成策略（周期性 · 标点式）
FlinkWatermark
07
Flink状态编程
Keyed State（ValueS… · ListState · MapState）
Flink状态编程
08
Flink Checkpoint与容错
Checkpoint原理 · Exactly-Once语义 · Savepoint与恢复
FlinkCheckpoint
09
Flink Window操作
滚动窗口 · 滑动窗口 · 会话窗口
FlinkWindow
10
Flink ProcessFunction
KeyedProcessFuncti… · TimerService · 侧输出流（Side Output）
FlinkProcessFunct…
11
Flink Table & SQL
Table API简介 · 动态表 · 流式SQL查询
FlinkTable
12
Flink与Kafka集成
Kafka Source/Sink配… · Kafka消息序列化（Avro/JS… · 分区分配策略
FlinkKafka
13
Flink与Redis集成
Redis Connector配置 · 维表关联（Async I/O） · 缓存策略
FlinkRedis
14
Flink与HBase集成
HBase Connector配置 · 批量写入优化 · RowKey设计
FlinkHBase
15
Flink CEP（复杂事件处理）
CEP模式定义 · Pattern API · 时间约束
FlinkCEP
16
Flink性能调优
并行度设置 · 算子链与资源槽 · 内存配置（堆内/堆外）
Flink性能调优
17
Flink反压机制
反压原理 · 背压监控（Web UI/指标） · 反压原因分析
Flink反压机制
18
Flink监控与告警
Flink Metrics（系统/用… · Prometheus + Grafa… · 日志采集（ELK）
Flink监控
19
灰度发布架构设计
灰度发布在实时系统中的架构模式 · 流量路由策略（基于标签/权重） · 配置中心（Nacos/Apollo）
灰度发布架构设计灰度发布
20
灰度发布数据隔离
多版本数据流隔离 · Schema兼容性（Avro演化） · 状态隔离（独立状态后端/命名空间）
灰度发布数据隔离多版本数据流隔离
21
灰度发布流量路由
基于Flink Side Outpu… · 基于Kafka Topic分区路由 · 基于自定义Router实现
灰度发布流量路由Flink
22
灰度发布版本管理
Flink Job版本化 · JAR包管理 · 版本回滚策略
灰度发布版本管理Flink
23
灰度发布监控对比
新旧版本指标对比（延迟 · 吞吐 · 正确率）
灰度发布监控对比新旧版本指标对比
24
高频行情数据模型
行情数据结构（Tick · K线 · OrderBook）
高频行情数据模型Tick
25
高频行情实时处理
行情数据接入（Kafka） · 行情清洗与校验 · 行情聚合（K线计算）
高频行情实时处理Kafka
26
高频行情延迟优化
低延迟网络（DPDK/RDMA） · JVM调优（GC优化） · 序列化优化（Kryo/Fastjso…
高频行情延迟优化DPDK/RDMA
27
高频行情与Flink CEP
基于CEP的行情模式识别（如大单突破 · 价差异常） · 实时告警与交易信号生成
FlinkCEP
28
灰度发布实战案例一
Flink Job灰度升级（从V1到… · 包括流量切换 · 状态迁移
灰度发布实战案例…Flink
29
灰度发布实战案例二
高频行情数据源灰度切换（从旧交易所A… · 包括双写 · 对比
灰度发布实战案例…高频行情数据源灰…
30
课程总结与展望
高频行情灰度发布最佳实践 · Flink未来演进（Flink 2.… · 实时计算与AI结合趋势
课程总结高频行情灰度发布…