实时数仓开发工程师

负责主题建模、指标口径与实时链路交付，保证指标可解释、可与离线对账，支撑看板、运营、风控等场景。工作重心在数仓与业务指标，不是流计算平台或集群内核开发。

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 任务并做基础监控排查。