码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • hudi系列-changelog的读写


    1. chanelog模式

    在以hudi的MOR表作为flink cdc的源时,出现了一些并非预期的效果。hudi自身支持ChangelogModes#FULL & ChangelogModes#UPSERT 两种模式,从它们支持的RowKind来看,还以为数据写入与读取时 RowKind是一致的,其实不然;另外,如果读写分别使用了不同的模式,那又会产生什么后果,我们应该怎么使用它。

    • 当changelog.enable=true时,为FULL模式,包含的RowKind有:INSERT , UPDATE_BEFORE , UPDATE_AFTER , DELETE
    • 当changelog.enable=false时,为UPSERT模式,包含的RowKind有:INSERT , UPDATE_AFTER , DELETE

    2. FULL模式

    2.1 写数据

    在该模式下,sink端会完整接收上流所有RowKind类型的数据,在hudi内部通过往行记录中增加元数据字段_hoodie_operation,并将该字段的值设置为RowKind的名称(+I,-U,+U,-D),通过查看生成的rt表和ro表结构,多了一列。

    org.
    • 相关阅读:
      Go基础12-理解Go语言表达式的求值顺序
      Spring Boot集成zipkin快速入门Demo
      【笔记】大话设计模式-567
      CICD 持续集成与持续交付——gitlab
      wordpress全站开发指南-面向开发者及深度用户(全中文实操)--wordpress是什么
      【Linux】基础IO
      每日一题 1458两个子序列的最大点积
      华为HCIA(六)
      Excel逆向查询的多种方法,赶快学起来
      c语言 任意进制数的转换
    • 原文地址:https://blog.csdn.net/czmacd/article/details/127622900
    • 最新文章
    • 【FHE】我们如何实现同态加密推理(八):SiLU 的密文化——两条路径,和一个 8 字节的开关
      SQLcl 中 c/old/new 替换变量为何失效?先定位再替换
      不让模型写作文,直接从它脑子里读答案:Jev 决策在 .NET 的两条路线
      Halo插件:支持GitHub的图床附件策略
      电视投屏界的“一股清流”!SimpleTVCast 6.0.0-beta 抢先体验:无需TV端App,界面大换血!✨
      华三VXLAN集中式网关实战指南:Spine多活网关 + 双活接入(M-LAG)
      软件更好写之后口碑会更重要
      大 O、大 Omega、大 Theta 的区别,O(n) 复杂度是什么意思
      Java标签跳转:一个鲜为人知但却很实用的小技巧
      多智能体系统论文速读
    • 热门文章
    • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
      奉劝各位学弟学妹们,该打造你的技术影响力了!
      五年了,我在 CSDN 的两个一百万。
      Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
      面试官都震惊,你这网络基础可以啊!
      你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
      心情不好的时候,用 Python 画棵樱花树送给自己吧
      通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
      13 万字 C 语言从入门到精通保姆级教程2021 年版
      10行代码集2000张美女图,Python爬虫120例,再上征途
    小工具 小游戏
    Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1

    京公网安备 11010502049817号