The posting
负责主题建模、指标口径与实时链路交付,保证指标可解释、可与离线对账,支撑看板、运营、风控等场景。工作重心在数仓与业务指标,不是流计算平台或集群内核开发。 1、按业务域建设实时 DWD / DWS / ADS 及维度体系,沉淀模型与口径说明; 2、与 BI、业务对齐指标定义、统计粒度、去重与窗口规则,维护实时与离线对账; 3、基于 Kafka + Flink SQL 做事件清洗、维表关联、窗口聚合与指标计算; 4、将结果写入 ClickHouse / Doris / StarRocks / Hologres 等(按公司实际栈),支撑 BI 与下游应用; 5、参与数仓规范、任务监控、故障排查与需求验收。
1、熟练 Kafka(Topic/消费组、Lag 与稳定性); 2、熟练 Flink SQL(窗口、维表 Join、Checkpoint;能处理重复、乱序对指标的影响); 3、有 Hive 或 Spark SQL 数仓分层经验;SQL 熟练; 4、熟悉、了解湖仓一体(离线/实时同源、流批一体;Iceberg / Hudi / Paimon 等湖表与 Flink/Spark 协同入湖与查询); 5、Java 或 Scala 能写 UDF、对账脚本;Python 可辅助开发与分析; 6、能运维线上 Flink 任务并做基础监控排查。



