Plink(天枢)⼀站式实时计算平台产品系统

我要开发同款
komahyz2026年09月22日
4阅读

技术信息

语言技术
JavaHadoopSpringMybatisHDFS
系统类型
Web
行业分类
企业服务

作品详情

行业场景

Java(Spring Boot)微服务 + Flink 构建的⼀站式实时 ETL 开发平台,把「⼿写 Flink 代码 + ⼿⼯提任务」变成
「平台上配置 + ⼀键发布」,统⼀集团实时计算的开发规范与交付流程。

功能介绍

平台侧(Java / Spring Boot 微服务):项⽬管理、任务管理(FlinkSQL / FlinkJar 双模式)、环境管理、版本与审
批流、任务参数配置、UDF 与 Connector 管理、⾎缘与⽇志、多环境发布、监控⼤盘、⽤户权限。
执⾏侧 plinker:作为多版本 Flink 集群的代理服务,向上屏蔽集群版本差异、向下适配 YARN 资源提交;把任务的
提交 / 停⽌ / Savepoint / 重启等⽣命周期操作统⼀收⼝,业务⽅⽆需关⼼底层是哪个 Flink 版本。
Flink 侧:FlinkSQL 任务的动态编译与校验(含 UDF 注册、Connector 装配),FlinkJar 任务的包版本管理;任务
上下游以 Kafka 为实时数据源与 Sink,结果数据集落在 Hadoop(HDFS / Hive)。
稳定性治理:按业务线隔离资源队列,任务级监控与告警;统⼀ Checkpoint 与反压 的默认配置基线与⽣产调优。

项目实现

实时计算(ETL)一站式开发平台:⽀撑客服、催收、⽤户、营销、⻛控特征、线下分期等集团业务线,纳管实时计算任务 1000+。

示例图片

声明:本文仅代表作者观点,不代表本站立场。如果侵犯到您的合法权益,请联系我们删除侵权资源!如果遇到资源链接失效,请您通过评论或工单的方式通知管理员。未经允许,不得转载,本站所有资源文章禁止商业使用运营!
下载安装【程序员客栈】APP
实时对接需求、及时收发消息、丰富的开放项目需求、随时随地查看项目状态

评论