登录社区云，与社区用户共同成长
邀请您加入社区
摘要：本项目构建了一个基于Apache Flink的铁路票务数据处理平台，实现HDFS文件到Hive数据仓库的实时转换。系统包含两个核心作业：1)文件处理作业定时扫描HDFS目录，解析票务和乘客信息文件并写入Parquet格式的Hive表；2)数据合并作业每小时关联两张源表生成完整车次信息。技术栈采用Flink 1.18.1流处理引擎，结合Kerberos认证保障安全，Quartz实现调度管理。系
