ETL

Flink 实时流计算与 ETL 体系

基于 Flink + 定时任务的金融数据管道。 核心能力: Flink CDC 实时数据同步(MySQL binlog / HBase 变更日志) Flink SQL 流式 ETL:实时清洗、聚合、窗口计算 分钟级 K线合成、买卖压力比、异常交易检测 Checkpoint 机制保证 Exactly-Once 语义 离线 ETL:Airflow + …