登录社区云，与社区用户共同成长
邀请您加入社区
摘要：本项目构建了一个基于Apache Flink的铁路票务数据处理平台，实现HDFS文件到Hive数据仓库的实时转换。系统包含两个核心作业：1)文件处理作业定时扫描HDFS目录，解析票务和乘客信息文件并写入Parquet格式的Hive表；2)数据合并作业每小时关联两张源表生成完整车次信息。技术栈采用Flink 1.18.1流处理引擎，结合Kerberos认证保障安全，Quartz实现调度管理。系
当调用getRuntimeContext().getState()时，底层会基于当前Key创建专属状态实例，实现多Key共享算子实例但状态隔离。定时器同样通过InternalTimerService与Key绑定，触发时会自动设置对应Key的上下文。具体实现上：定时器注册时将Key编码到TimerHeapInternalTimer，触发时通过keyContext.setCurrentKey还原Key
