跳到主要内容

案例分享:LakeSoul 独有的 MergeOperator 功能

· 阅读需 1 分钟

近日,LakeSoul 研发团队帮助用户解决了一个使用 Hudi 过程中遇到的实际的业务问题,在这里做个总结记录。大体业务流程是上游系统从线上 DB 表中抽取原始数据转换成 json 格式,写入 Kafka ,下游使用 Spark 读取 Kafka 中的消息,原先使用 Hudi 将数据更新聚合后,发送给下游数据库分析。

点击阅读原文