基于 Flink + CDC 的实时数据管道 — 数据抽取、清洗、转换、装载一站式自动化,构建企业级 ODS / DW / ADS 分层数据仓库,消灭数据孤岛。
Flink + CDC 双引擎,毫秒级感知源端变更,实时入仓。
主流数据库、SaaS、ERP、IoT、文件、API — 应接尽接。
拖拽式 DAG 编排,无需写 Spark / Flink 代码即可上线。
血缘追溯、质量监控、指标管理、维度建模四件套齐全。
关系数据库、NoSQL、文件、对象存储、消息队列、SaaS、API、IoT — 200+ 连接器开箱即用,自定义连接器 SDK 自由扩展。
基于 Debezium / Flink CDC 监听数据库 binlog / redo log,毫秒级感知 insert / update / delete,源端零侵入。
拖拽式构建数据管道,节点支持 SQL / Python / Shell / Spark,实时校验依赖关系,所见即所得部署上线。
Cron 表达式 + 事件触发 + 数据到达触发,支持上下游依赖、跨工作流依赖、失败重试、补数运行。
空值率、唯一性、值域、参考完整性、自定义规则五大维度持续巡检 — 异常自动告警、回滚、阻断下游。
字段级、表级、任务级三层血缘自动构建,可视化展示 — 一个字段从哪来、到哪去、谁在用,一目了然。
ODS / DWD / DWS / ADS 标准四层,内置维度建模模板,支持星型、雪花、宽表三种范式 — 模型即代码,Git 版本化。
原子指标 + 派生指标 + 复合指标三级体系,定义一次、全公司复用 — 杜绝"一个指标多个口径"的撕扯。
统一管理客户、供应商、物料、组织、员工等核心实体,跨系统一致性校验,主索引唯一标识。
支持 Iceberg / Hudi / Paimon 三大数据湖格式,实现存储计算分离,冷热数据分层,降本最高 60%。
历史区间一键重跑,智能识别上下游影响范围,避免重复计算 — 大表回溯也能在小时级完成。
把指标、明细、宽表一键发布为 RESTful API / GraphQL,支持限流、鉴权、缓存 — 让业务系统反向消费数仓。
不光给工具,还给方法论 — 4 周内完成首批数据上线,12 周完成核心主题域全量入仓。
同一套 ETL 工厂,既能跑央企 480+ 张表的复杂场景,也能跑中型企业 50 张表的轻量场景。
— 几何ETL 数据集成与治理平台 单平台官方定价，多平台组合与集团授权请联系销售顾问 —
